org.apache.tuscany.sca.invocation.Message.setOperation()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(5.1k)|赞(0)|评价(0)|浏览(257)

本文整理了Java中org.apache.tuscany.sca.invocation.Message.setOperation()方法的一些代码示例,展示了Message.setOperation()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Message.setOperation()方法的具体详情如下:
包路径:org.apache.tuscany.sca.invocation.Message
类名称:Message
方法名:setOperation

Message.setOperation介绍

[英]Sets the operation that created the message.
[中]设置创建消息的操作。

代码示例

代码示例来源:origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. public void invokeAsync(Operation operation, Message msg){
  2. msg.setOperation(operation);
  3. invoker.invokeAsync(msg);
  4. }

代码示例来源:origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. public void invokeAsync(Operation operation, Message msg){
  2. msg.setOperation(operation);
  3. invoker.invokeAsync(msg);
  4. } // end method invokeAsync(Operation, Message)

代码示例来源:origin: org.apache.tuscany.sca/tuscany-binding-http-runtime

  1. @Override
  2. public Message invoke(Message msg) {
  3. HTTPContext context = msg.getBindingContext();
  4. HttpServletRequest request = context.getHttpRequest();
  5. String path = request.getPathInfo();
  6. if (path.startsWith("/")) {
  7. path = path.substring(1);
  8. }
  9. for (Operation op : operations) {
  10. if (op.getName().equals(path)) {
  11. msg.setOperation(op);
  12. return next.invoke(msg);
  13. }
  14. }
  15. throw new ServiceRuntimeException("No matching operation: " + path);
  16. }

代码示例来源:origin: org.apache.tuscany.sca/tuscany-binding-jms-runtime

  1. public Message invokeRequest(Message msg) {
  2. // get the jms context
  3. JMSBindingContext context = msg.getBindingContext();
  4. javax.jms.Message jmsMsg = context.getJmsMsg();
  5. Operation operation = getTargetOperation(jmsMsg);
  6. msg.setOperation(operation);
  7. return msg;
  8. }

代码示例来源:origin: org.apache.tuscany.sca/tuscany-binding-jms-runtime

  1. public Message invokeRequest(Message msg) {
  2. // TODO - could probably optimize this better
  3. String operationName = msg.getOperation().getName();
  4. String operationNameOverride = jmsBinding.getOpNameFromNativeOperationName(operationName);
  5. if (operationNameOverride != null) {
  6. for (Operation op : serviceOperations) {
  7. if (op.getName().equals(operationNameOverride)) {
  8. msg.setOperation(op);
  9. break;
  10. }
  11. }
  12. }
  13. return msg;
  14. }

代码示例来源:origin: org.apache.tuscany.sca/tuscany-binding-http-runtime

  1. @Override
  2. public Message invoke(Message msg) {
  3. HTTPContext context = msg.getBindingContext();
  4. HttpServletRequest request = context.getHttpRequest();
  5. Operation operation = findOperation(request.getMethod());
  6. if(operation == null) {
  7. operation = findOperation("service");
  8. }
  9. if(operation == null) {
  10. throw new ServiceRuntimeException("No matching operation for " + request.getMethod());
  11. }
  12. msg.setOperation(operation);
  13. return next.invoke(msg);
  14. }

代码示例来源:origin: org.apache.tuscany.sca/tuscany-binding-jms-runtime

  1. public Message invokeRequest(Message msg) {
  2. // get the jms context
  3. JMSBindingContext context = msg.getBindingContext();
  4. javax.jms.Message jmsMsg = context.getJmsMsg();
  5. String operationName = requestMessageProcessor.getOperationName(jmsMsg);
  6. Operation operation = getTargetOperation(operationName, jmsMsg);
  7. msg.setOperation(operation);
  8. return msg;
  9. }

代码示例来源:origin: org.apache.tuscany.sca/tuscany-binding-jms-runtime

  1. public Message processResponse(Message msg) {
  2. // When the response message arrives, there may be information about the
  3. // operation and the related request message ID in the headers - extract it into the
  4. // Tuscany message
  5. javax.jms.Message responseMsg = msg.getBody();
  6. try {
  7. // Operation name...
  8. String operationName = responseMsg.getStringProperty("scaOperationName");
  9. for( Operation op : operations ) {
  10. if( operationName.equals(op.getName())) {
  11. msg.setOperation(op);
  12. break;
  13. } // end if
  14. } // end for
  15. // Relates to header...
  16. String relatesTo = responseMsg.getStringProperty("RELATES_TO");
  17. if( relatesTo != null ) {
  18. msg.getHeaders().put("RELATES_TO", relatesTo);
  19. } // end if
  20. } catch (JMSException e) {
  21. // TODO Auto-generated catch block
  22. } // end try
  23. return msg;
  24. } // end method processResponse

代码示例来源:origin: org.apache.tuscany.sca/tuscany-binding-rest-runtime

  1. msg.setOperation(operation);

代码示例来源:origin: org.apache.tuscany.sca/tuscany-binding-rest-runtime

  1. msg.setOperation(operation);

代码示例来源:origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. public Message invoke(InvocationChain chain, Message msg) {
  2. if (invocable instanceof Endpoint) {
  3. msg.setTo((Endpoint)invocable);
  4. } else if (invocable instanceof EndpointReference) {
  5. msg.setFrom((EndpointReference)invocable);
  6. }
  7. Invoker headInvoker = chain.getHeadInvoker();
  8. Operation operation = chain.getTargetOperation();
  9. msg.setOperation(operation);
  10. Message msgContext = ThreadMessageContext.setMessageContext(msg);
  11. try {
  12. return headInvoker.invoke(msg);
  13. } finally {
  14. ThreadMessageContext.setMessageContext(msgContext);
  15. }
  16. }

代码示例来源:origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. msg.setOperation(getOperation( args ));

代码示例来源:origin: org.apache.tuscany.sca/tuscany-binding-ws-runtime-axis2

  1. msg.setOperation(operation);
  2. WSAxis2BindingContext bindingContext = new WSAxis2BindingContext();
  3. bindingContext.setAxisInMessageContext(inMC);

代码示例来源:origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. operation = chain.getTargetOperation();
  2. msg.setOperation(operation);
  3. msg.setBody(args);

代码示例来源:origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. msg.setOperation(operation);
  2. msg.setBody(args);

代码示例来源:origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. operation = chain.getTargetOperation();
  2. msg.setOperation(operation);
  3. msg.setBody(args);

代码示例来源:origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. Object[] body = new Object[]{root};
  2. requestMsg.setBody(body);
  3. requestMsg.setOperation(operation);

相关文章