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

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

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

Message.setBindingContext介绍

[英]Set the binding context that is in force for this message
[中]设置对此消息有效的绑定上下文

代码示例

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

  1. @Override
  2.   protected void service(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
  3.     HTTPContext bindingContext = new HTTPContext();
  4.     bindingContext.setHttpRequest(request);
  5.     bindingContext.setHttpResponse(response);
  6.     Message msg = messageFactory.createMessage();
  7.     msg.setBindingContext(bindingContext);
  8.     Message responseMessage = wire.invoke(msg);
  9.     // return response to client
  10.     if (responseMessage.isFault()) {
  11.       // Turn a fault into an exception
  12.       Throwable e = (Throwable)responseMessage.getBody();
  13.       response.sendError(HttpServletResponse.SC_INTERNAL_SERVER_ERROR, e.toString());
  14.     } 
  15.   }    
  16. }

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

  1. requestMessage.setBindingContext(bindingContext);

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

  1. requestMessage.setBindingContext(bindingContext);
  2. requestMessage.setBody(new Object[]{request, response});
  3. Message responseMessage = serviceInvoker.invoke(requestMessage);

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

  1. protected void invokeReference(Message requestJMSMsg) throws JMSException, InvocationTargetException {
  2.   // create the Tuscany message
  3.   org.apache.tuscany.sca.invocation.Message tuscanyMsg = messageFactory.createMessage();
  4.   
  5.   // populate the message context with JMS binding information
  6.   JMSBindingContext context = new JMSBindingContext();
  7.   tuscanyMsg.setBindingContext(context);
  8.   
  9.   context.setJmsMsg(requestJMSMsg);
  10.   context.setJmsResourceFactory(jmsResourceFactory);
  11.   context.setReplyToDestination(requestJMSMsg.getJMSReplyTo());
  12.   
  13.   
  14.   
  15.   // set the message body
  16.   tuscanyMsg.setBody(requestJMSMsg);
  17.   
  18.   // call the runtime wire - the response is handled by the 
  19.   // transport interceptor
  20.   endpointReference.invokeAsyncResponse(tuscanyMsg);
  21.     
  22. } // end method invokeReference

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

  1. /**
  2.  * Process forward request message
  3.  * @param tuscanyMsg - the request message
  4.  * @return the processed version of the request message
  5.  */
  6. public Message processRequest(Message tuscanyMsg) {
  7.   try {
  8.     // populate the message context with JMS binding information
  9.     JMSBindingContext context = new JMSBindingContext();
  10.     context.setJmsResourceFactory(jmsResourceFactory);
  11.     tuscanyMsg.setBindingContext(context);
  12.     
  13.     // get a JMS session to cover the creation and sending of the message
  14.     Session session = context.getJmsSession();
  15.     context.setRequestDestination(getRequestDestination(tuscanyMsg, session));
  16.     context.setReplyToDestination(getReplyToDestination(session));
  17.     
  18.     return tuscanyMsg;
  19.   } catch (Exception e) {
  20.     throw new JMSBindingException(e);
  21.   } // end try   
  22. } // end method processRequest

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

  1. public Message invokeResponse(Message msg) {
  2.   // get the jms context
  3.   JMSBindingContext context = msg.getBindingContext();
  4.   // The Binding Context may be null on an asynchronous response - in which case, create a new one
  5.   if(context == null) {
  6.     context = createBindingContext();
  7.     msg.setBindingContext(context);
  8.   }
  9.   Session session = context.getJmsResponseSession();
  10.   javax.jms.Message responseJMSMsg;
  11.   if (msg.isFault()) {
  12.     responseJMSMsg = responseMessageProcessor.createFaultMessage(session, (Throwable)msg.getBody());
  13.   } else {
  14.     Object response = msg.getBody();
  15.     responseJMSMsg = responseMessageProcessor.insertPayloadIntoJMSMessage(session, response);
  16.   } 
  18.   msg.setBody(responseJMSMsg);
  19.   
  20.   return msg;
  21. }

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

  1. public Message invokeResponse(Message msg) {
  2.   
  3.   // get the jms context
  4.   JMSBindingContext context = msg.getBindingContext();
  5.   // The Binding Context may be null on an asynchronous response - in which case, create a new one
  6.   if(context == null) {
  7.     context = createBindingContext();
  8.     msg.setBindingContext(context);
  9.   }
  10.   Session session = context.getJmsResponseSession();
  11.   javax.jms.Message responseJMSMsg;
  12.   if (msg.isFault()) {
  13.     responseJMSMsg = responseMessageProcessor.createFaultMessage(session, (Throwable)msg.getBody());
  14.   } else {
  15.     responseJMSMsg = responseMessageProcessor.insertPayloadIntoJMSMessage(session, msg.getBody());
  16.   }
  18.   msg.setBody(responseJMSMsg);
  19.   
  20.   return msg;
  21. }

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

  1. public Message invokeResponse(Message msg) {
  2.   // get the jms context
  3.   JMSBindingContext context = msg.getBindingContext();
  4.   // The Binding Context may be null on an asynchronous response - in which case, create a new one
  5.   if(context == null) {
  6.     context = createBindingContext();
  7.     msg.setBindingContext(context);
  8.   }
  9.   Session session = context.getJmsResponseSession();
  10.   javax.jms.Message responseJMSMsg;
  11.   if (msg.isFault()) {
  12.     responseJMSMsg = responseMessageProcessor.createFaultMessage(session, (Throwable)msg.getBody());
  13.   } else {
  14.     Object response = msg.getBody();
  15.     responseJMSMsg = responseMessageProcessor.insertPayloadIntoJMSMessage(session, response);
  16.   } 
  18.   msg.setBody(responseJMSMsg);
  19.   
  20.   return msg;
  21. }

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

  1. public Message invokeResponse(Message msg) {
  2.   // get the jms context
  3.   JMSBindingContext context = msg.getBindingContext();
  4.   
  5.   // The Binding Context may be null on an asynchronous response - in which case, create a new one
  6.   if(context == null) {
  7.     context = createBindingContext();
  8.     msg.setBindingContext(context);
  9.   }
  10.   Session session = context.getJmsResponseSession();
  11.   javax.jms.Message responseJMSMsg = null;
  12.   if (msg.isFault()) {
  13.     responseJMSMsg = responseMessageProcessor.createFaultMessage(session, (Throwable)msg.getBody());
  14.   } else {
  15.     responseJMSMsg = responseMessageProcessor.insertPayloadIntoJMSMessage(session, msg.getBody());
  16.   } 
  18.   msg.setBody(responseJMSMsg);
  19.   
  20.   return msg;
  21. }

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

  1. bindingContext.setAxisInMessageContext(inMC);
  2. msg.setBindingContext(bindingContext);

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

  1. public Message invokeResponse(Message msg) {
  2.   // get the jms context
  3.   JMSBindingContext context = msg.getBindingContext();
  4.   // The Binding Context may be null on an asynchronous response - in which case, create a new one
  5.   if(context == null) {
  6.     context = createBindingContext();
  7.     msg.setBindingContext(context);
  8.   }
  9.   Session session = context.getJmsResponseSession();
  10.   javax.jms.Message responseJMSMsg;
  11.   if (msg.isFault()) {
  12.     responseJMSMsg = responseMessageProcessor.createFaultMessage(session, (Throwable)msg.getBody());
  13.   } else {
  14.     Object response = msg.getBody();
  15.     responseJMSMsg = responseMessageProcessor.insertPayloadIntoJMSMessage(session, response);
  16.   }  
  18.   msg.setBody(responseJMSMsg);
  19.   
  20.   return msg;
  21. }

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

  1. protected void invokeService(Message requestJMSMsg) throws JMSException, InvocationTargetException {
  2.   // create the tuscany message
  3.   org.apache.tuscany.sca.invocation.Message tuscanyMsg = messageFactory.createMessage();
  4.   
  5.   // populate the message context with JMS binding information
  6.   JMSBindingContext context = new JMSBindingContext();
  7.   tuscanyMsg.setBindingContext(context);
  8.   
  9.   context.setJmsMsg(requestJMSMsg);
  10.   context.setJmsResourceFactory(jmsResourceFactory);
  11.   context.setReplyToDestination(requestJMSMsg.getJMSReplyTo());
  12.   
  13.   // set the message body
  14.   tuscanyMsg.setBody(requestJMSMsg);
  15.   
  16.   // call the runtime wire - the response is handled by the 
  17.   // transport interceptor
  18.   //getEndpoint(targetBinding).invoke(tuscanyMsg);
  19.   RuntimeEndpoint endpoint = getEndpoint(targetBinding);
  20.   if( endpoint.isAsyncInvocation() ) {
  21.     endpoint.invokeAsync(tuscanyMsg);
  22.   } else {
  23.     endpoint.invoke(tuscanyMsg);
  24.   } // end if
  25.     
  26. } // end method invokeService

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

  1. msg.setBindingContext(context);

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

  1. msg.setBindingContext(bindingContext);

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

  1. tuscanyMsg.setBindingContext(context);

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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