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

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

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

Message.getOperation介绍

[英]Returns the operation that created the message.
[中]返回创建消息的操作。

代码示例

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

  1. public Message invoke(Message msg) {
  2.   return invoke(msg.getOperation(), msg);
  3. }

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

  1. private Message invokeRequest(Message msg) throws IOException {
  2.   HTTPContext context = msg.getBindingContext();
  3.   HttpServletRequest servletRequest = context.getHttpRequest();
  4.   if ("GET".equals(servletRequest.getMethod())) {
  5.     msg.setBody(getRequestFromQueryString(msg.getOperation(), servletRequest));
  6.   } else {
  7.     msg.setBody(getRequestFromPost(msg.getOperation(), servletRequest));
  8.   }
  9.   return msg;
  10. }

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

  1. private Object invokeTarget(Message msg) throws InvocationTargetException {
  2.   Operation op = msg.getOperation();
  3.   if (op == null) {
  4.     op = this.operation;
  5.   }
  6.   try {
  7.     Object instance = provider.getOSGiService(service);
  8.     Method m = findMethod(instance.getClass(), operation);
  9.     Object ret = invokeMethod(instance, m, msg);
  10.     return ret;
  11.   } catch (InvocationTargetException e) {
  12.     throw e;
  13.   } catch (Exception e) {
  14.     throw new InvocationTargetException(e);
  15.   }
  16. }

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

  1. /**
  2.  * Initiate the sending of the response part of an asynchronous
  3.  * exchange along the response part of the wire. 
  4.  * 
  5.  * @param msg the response message
  6.  */
  7. public void invokeAsyncResponse(Message msg) {  
  8.   InvocationChain chain = invocable.getInvocationChain(msg.getOperation());
  9.   Invoker tailInvoker = chain.getTailInvoker();
  10.   ((InvokerAsyncResponse)tailInvoker).invokeAsyncResponse(msg);       
  11. } // end method invokeAsyncResponse

代码示例来源：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.   
  6.   if (operationNameOverride != null) {
  7.     for (Operation op : serviceOperations) {
  8.       if (op.getName().equals(operationNameOverride)) {
  9.         msg.setOperation(op);
  10.         break;
  11.       }
  12.     }
  13.   }
  14.   return msg;
  15. }

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

  1. private Message invokeRequest(Message msg) throws IOException, SAXException {
  2.   HTTPContext context = msg.getBindingContext();
  3.   HttpServletRequest servletRequest = context.getHttpRequest();
  4.   if ("GET".equals(servletRequest.getMethod())) {
  5.     msg.setBody(getRequestFromQueryString(msg.getOperation(), servletRequest));
  6.   } else {
  7.     msg.setBody(new Object[]{domHelper.load(read(servletRequest))});
  8.   }
  9.   return msg;
  10. }

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

  1. /**
  2.  * Setup the necessary infrastructure for the Async response handling
  3.  * @param msg
  4.  * @param callbackAddress 
  5.  */
  6. private void setupAsyncResponse(Message msg, String callbackAddress) {
  7.   if( !endpoint.isAsyncInvocation() ) return;
  8.   endpoint.createAsyncServerCallback();
  9.   RuntimeEndpointReference asyncCallback = endpoint.getAsyncServerCallback();
  10.   
  11.   // Create a response invoker, containing the callback address and add it to the message headers
  12.   AsyncResponseInvoker<String> respInvoker = 
  13.     new AsyncResponseInvoker<String>(endpoint, asyncCallback,
  14.         callbackAddress, 
  15.         (String)msg.getHeaders().get(Constants.MESSAGE_ID),
  16.         msg.getOperation().getName(), messageFactory);
  17.   msg.getHeaders().put(Constants.ASYNC_RESPONSE_INVOKER, respInvoker);
  18. } // end method setupAsyncResponse

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

  1. public Message invoke(Message msg) {
  2.   try {
  3.     Object resp = doInvoke((Object[])msg.getBody(), msg.getOperation());
  4.     msg.setBody(resp);
  5.   } catch (ScriptException e) {
  6.     msg.setFaultBody(e.getCause());
  7.   }
  8.   return msg;
  9. }

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

  1. public Message invokeRequest(Message msg) {
  2.   try {
  3.     // get the jms context
  4.     JMSBindingContext context = msg.getBindingContext();
  5.     Session session = context.getJmsSession();
  6.     javax.jms.Message requestMsg;
  7.     if (((WireFormatJMSDefault) jmsBinding.getRequestWireFormat()).isUseBytesMessage()) {
  8.       requestMsg = requestMessageProcessor.insertPayloadIntoJMSBytesMessage(session, msg.getBody(), this.inputWrapperMap.get(msg.getOperation().getName()));
  9.     } else {
  10.       requestMsg = requestMessageProcessor.insertPayloadIntoJMSTextMessage(session, msg.getBody(), this.inputWrapperMap.get(msg.getOperation().getName()));
  11.     }
  12.     msg.setBody(requestMsg);
  13.     requestMsg.setJMSReplyTo(context.getReplyToDestination());
  14.     return msg;
  15.   } catch (JMSException e) {
  16.     throw new JMSBindingException(e);
  17.   }
  18. }

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

  1. public Message invoke(Message msg) {
  2.   Message responseMsg = invokeRequest(msg);
  3.   
  4.   // get the jms context
  5.   JMSBindingContext context = msg.getBindingContext();
  6.   
  7.   // [rfeng] For oneway operation as part of the bi-directional interface, the JMSReplyTo is present
  8.   if (context.getReplyToDestination() == null || msg.getOperation().isNonBlocking()) {
  9.     responseMsg.setBody(null);
  10.   } else {
  11.     responseMsg = invokeResponse(msg);
  12.   }
  13.   
  14.   return responseMsg;
  15. }

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

  1. public void invokeAsyncResponse(Message msg){
  2.   // If there is a Binding Chain, invoke it first...
  3.   InvocationChain chain = this.getBindingInvocationChain();
  4.   if( chain != null ) {
  5.     Invoker tailInvoker = chain.getTailInvoker();
  6.     if (tailInvoker != null) {
  7.       ((InvokerAsyncResponse)tailInvoker).invokeAsyncResponse(msg);
  8.     } // end if
  9.   } // end if
  10.   
  11.   chain = this.getInvocationChain(msg.getOperation());
  12.   Invoker tailInvoker = chain.getTailInvoker();
  13.   ((InvokerAsyncResponse)tailInvoker).invokeAsyncResponse(msg);   
  14. } // end method invokeAsyncResponse

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

  1. public Message invoke(Message msg) {
  2.   
  3.   if (jmsBinding.getRequestWireFormat() instanceof WireFormatJMSDefault) {
  4.     msg = invokeRequest(msg);
  5.   }
  6.   msg = getNext().invoke(msg);
  7.   // if it's oneway return back
  8.   Operation operation = msg.getOperation();
  9.   if (operation != null && operation.isNonBlocking()) {
  10.     return msg;
  11.   }
  12.   if (jmsBinding.getResponseWireFormat() instanceof WireFormatJMSDefault) {
  13.     msg = invokeResponse(msg);
  14.   }
  15.   return msg;
  16. }

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

  1. public Message invoke(Message msg) {
  2.   if (jmsBinding.getRequestWireFormat() instanceof WireFormatJMSBytesXML){
  3.     msg = invokeRequest(msg);
  4.   }
  5.   
  6.   msg = getNext().invoke(msg);
  7.   
  8.   //if it's oneway return back
  9.   Operation operation = msg.getOperation();
  10.   if (operation != null && operation.isNonBlocking()) {
  11.     return msg;
  12.   }
  13.   if (jmsBinding.getResponseWireFormat() instanceof WireFormatJMSBytesXML){
  14.     msg = invokeResponse(msg);
  15.   }
  16.   
  17.   return msg;
  18. }

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

  1. public Message invoke(Message msg) {
  2.   if (jmsBinding.getRequestWireFormat() instanceof WireFormatJMSTextXML){
  3.     msg = invokeRequest(msg);
  4.   }
  5.   
  6.   msg = getNext().invoke(msg);
  7.   
  8.   //if it's oneway return back
  9.   Operation operation = msg.getOperation();
  10.   if (operation != null && operation.isNonBlocking()) {
  11.     return msg;
  12.   }
  13.   if (jmsBinding.getResponseWireFormat() instanceof WireFormatJMSTextXML){
  14.     msg = invokeResponse(msg);
  15.   }
  16.   
  17.   return msg;
  18. }

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

  1. public Message invoke(Message msg) {
  2.   if (jmsBinding.getRequestWireFormat() instanceof WireFormatJMSBytes){
  3.     msg = invokeRequest(msg);
  4.   }
  5.   
  6.   msg = getNext().invoke(msg);
  7.   
  8.   //if it's oneway return back
  9.   Operation operation = msg.getOperation();
  10.   if (operation != null && operation.isNonBlocking()) {
  11.     return msg;
  12.   }
  13.   if (jmsBinding.getResponseWireFormat() instanceof WireFormatJMSBytes){
  14.     msg = invokeResponse(msg);
  15.   }
  16.   
  17.   return msg;
  18. }

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

  1. public Message invoke(Message msg) {
  2.   if (jmsBinding.getRequestWireFormat() instanceof WireFormatJMSText){
  3.     msg = invokeRequest(msg);
  4.   }
  5.   
  6.   msg = getNext().invoke(msg);
  7.   
  8.   //if it's oneway return back
  9.   Operation operation = msg.getOperation();
  10.   if (operation != null && operation.isNonBlocking()) {
  11.     return msg;
  12.   }
  13.   if (jmsBinding.getResponseWireFormat() instanceof WireFormatJMSText){
  14.     msg = invokeResponse(msg);
  15.   }
  16.   
  17.   return msg;
  18. }

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

  1. public Message invoke(Message msg) {
  2.   if (jmsBinding.getRequestWireFormat() instanceof WireFormatJMSObject){
  3.     msg = invokeRequest(msg);
  4.   }
  5.   
  6.   msg = getNext().invoke(msg);
  7.   
  8.   //if it's oneway return back
  9.   Operation operation = msg.getOperation();
  10.   if (operation != null && operation.isNonBlocking()) {
  11.     return msg;
  12.   }
  13.   if (jmsBinding.getResponseWireFormat() instanceof WireFormatJMSObject){
  14.     msg = invokeResponse(msg);
  15.   }
  16.   
  17.   return msg;
  18. }

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

  1. public Message invoke(Message msg) {
  2.   HTTPContext bindingContext = (HTTPContext) msg.getBindingContext();
  3.   if (bindingContext == null) {
  4.     return getNext().invoke(msg);
  5.   }
  6.   if (binding.getRequestWireFormat() instanceof XMLWireFormat) {
  7.     if( isPayloadSupported(bindingContext.getHttpRequest().getMethod()) && msg.getBody() != null) {
  8.       msg = invokeRequest(bindingContext, msg);
  9.     }
  10.   }
  11.   msg = getNext().invoke(msg);
  12.   //if it's oneway return back
  13.   Operation operation = msg.getOperation();
  14.   if (operation != null && operation.isNonBlocking()) {
  15.     return msg;
  16.   }
  17.   if (binding.getResponseWireFormat() instanceof XMLWireFormat) {
  18.     msg = invokeResponse(bindingContext, msg);
  19.   }
  20.   return msg;
  21. }

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

  1. public Message invoke(Message msg) {
  2.   HTTPContext bindingContext = (HTTPContext) msg.getBindingContext();
  3.   if (bindingContext == null) {
  4.     return getNext().invoke(msg);
  5.   }
  6.   if (binding.getRequestWireFormat() instanceof JSONWireFormat) {
  7.     if( isPayloadSupported(bindingContext.getHttpRequest().getMethod()) && msg.getBody() != null) {
  8.       msg = invokeRequest(bindingContext, msg);
  9.     }
  10.   }
  11.   msg = getNext().invoke(msg);
  12.   //if it's oneway return back
  13.   Operation operation = msg.getOperation();
  14.   if (operation != null && operation.isNonBlocking()) {
  15.     return msg;
  16.   }
  17.   if (binding.getResponseWireFormat() instanceof JSONWireFormat) {
  18.     msg = invokeResponse(bindingContext, msg);
  19.   }
  20.   return msg;
  21. }

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

  1. public Message invoke(Message msg) {
  2.   try {
  3.     Object resp = null; 
  4.     
  5.     if (msg.getOperation().isNonBlocking()) {
  6.       resp = invokeTargetOneWay(msg);
  7.     } else {
  8.       resp = invokeTarget(msg);
  9.     }
  10.     
  11.     msg.setBody(resp);
  12.   } catch (AxisFault e) {
  13.     if (e.getDetail() != null ) {
  14.       FaultException f = new FaultException(e.getMessage(), e.getDetail(), e);
  15.       f.setFaultName(e.getDetail().getQName());
  16.       msg.setFaultBody(f);
  17.     } else {
  18.       msg.setFaultBody(e);
  19.     }
  20.   } catch (Throwable e) {
  21.     msg.setFaultBody(e);
  22.   }
  23.   return msg;
  24. }

内容来源于网络，如有侵权，请联系作者删除！

Message

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com