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

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

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

Message.getBindingContext介绍

[英]Returns the binding context in force for this message
[中]返回此消息的有效绑定上下文

代码示例

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

  1. private Message invokeResponse(Message msg) throws IOException {
  2.   HTTPContext context = msg.getBindingContext();
  3.   HttpServletRequest servletRequest = context.getHttpRequest();
  4.   HttpServletResponse servletResponse = context.getHttpResponse();
  5.   
  6.   if (msg.isFault()) {            
  7.     servletResponse.sendError(HttpServletResponse.SC_INTERNAL_SERVER_ERROR, String.valueOf(msg.getBody()));
  8.   } else {
  9.     String response = getResponseAsString(servletRequest, servletResponse, msg.getBody());
  10.     servletResponse.getOutputStream().println(response);
  11.   }
  12.   
  13.   return 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.   Object requestPayload = requestMessageProcessor.extractPayloadFromJMSMessage(jmsMsg);
  6.   msg.setBody(new Object[]{requestPayload});
  7.          return msg;
  8. }

代码示例来源：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.   Object requestPayload = requestMessageProcessor.extractPayloadFromJMSMessage(jmsMsg);
  6.   msg.setBody(new Object[] { requestPayload });
  7.   return msg;
  8. }

代码示例来源：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.   
  16.   throw new ServiceRuntimeException("No matching operation: " + path);
  17. }

代码示例来源：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.   Object requestPayload = requestMessageProcessor.extractPayloadFromJMSMessage(jmsMsg);
  6.   msg.setBody(new Object[]{requestPayload});
  7.          return msg;
  8. }

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

  1. public Message invoke(Message msg) {
  2.     // get the jms context
  3.     JMSBindingContext context = msg.getBindingContext();
  4.     javax.jms.Message jmsMsg = msg.getBody();
  6.     // JMS header attrs set on MessageProducer via interceptors.
  7.           
  8.     return getNext().invoke(msg);
  9. }

代码示例来源：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.   Object requestPayload = requestMessageProcessor.extractPayloadFromJMSMessage(jmsMsg);
  6.   msg.setBody(new Object[]{requestPayload});
  7.          return msg;
  8. }

代码示例来源：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-ws-runtime-axis2

  1. protected Object invokeTargetOneWay(Message msg) throws AxisFault {
  2.   WSAxis2BindingContext bindingContext = msg.getBindingContext();
  3.   OperationClient operationClient = bindingContext.getAxisOperationClient();
  4.   // ensure connections are tracked so that they can be closed by the reference binding
  5.   MessageContext requestMC = operationClient.getMessageContext("Out");
  6.   //requestMC.getOptions().setProperty(HTTPConstants.REUSE_HTTP_CLIENT, Boolean.TRUE);
  7.   Options opt = requestMC.getOptions();
  8.   opt.setProperty(HTTPConstants.REUSE_HTTP_CLIENT, Boolean.TRUE);
  9.   opt.setUseSeparateListener(true);
  10.   opt.setProperty(HTTPConstants.AUTO_RELEASE_CONNECTION,Boolean.TRUE);        
  11.   operationClient.execute(false);
  12.   // REVIEW it seems ok to return null
  13.   return null;
  14. }

代码示例来源：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-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-binding-http-runtime

  1. @Override
  2. public Message invoke(Message msg) {
  3.   HTTPContext context = msg.getBindingContext();
  4.   HttpServletRequest request = context.getHttpRequest();
  5.   
  6.   Operation operation = findOperation(request.getMethod());
  7.   if(operation == null) {
  8.     operation = findOperation("service");
  9.   }
  10.   
  11.   if(operation == null) {
  12.     throw new ServiceRuntimeException("No matching operation for " + request.getMethod());
  13.   }
  14.   msg.setOperation(operation);
  15.   return next.invoke(msg);        
  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.     
  6.     String operationName = requestMessageProcessor.getOperationName(jmsMsg);
  7.     Operation operation = getTargetOperation(operationName, jmsMsg);
  8.     msg.setOperation(operation);
  9.     return msg;
  10. }

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

  1. @Override
  2.   public Message invoke(Message msg) {
  3.     HTTPContext context = msg.getBindingContext();
  5.     msg.setBody(new Object[] {context.getHttpRequest(), context.getHttpResponse()});
  6.     return getNext().invoke(msg);
  7.   }
  8. }

代码示例来源：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-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.     
  7.     javax.jms.Message requestMsg = requestMessageProcessor.insertPayloadIntoJMSMessage(session, msg.getBody());
  8.     msg.setBody(requestMsg);
  9.     
  10.     requestMsg.setJMSReplyTo(context.getReplyToDestination());
  11.     
  12.     return msg;
  13.   } catch (JMSException e) {
  14.     throw new JMSBindingException(e);
  15.   } 
  16. }

代码示例来源：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.     
  7.     javax.jms.Message requestMsg = requestMessageProcessor.insertPayloadIntoJMSMessage(session, msg.getBody());
  8.     
  9.     msg.setBody(requestMsg);
  10.     
  11.     requestMsg.setJMSReplyTo(context.getReplyToDestination());
  12.     
  13.     return msg;
  14.   } catch (JMSException e) {
  15.     throw new JMSBindingException(e);
  16.   } 
  17. }

代码示例来源：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.     
  7.     Object[] requestParams = msg.getBody();
  8.     javax.jms.Message requestMsg = null;
  9.     if (requestParams != null && requestParams.length > 0 ){
  10.       requestMsg = requestMessageProcessor.insertPayloadIntoJMSMessage(session, requestParams[0]);
  11.     } else {
  12.       requestMsg = requestMessageProcessor.insertPayloadIntoJMSMessage(session, null);
  13.     }
  14.     msg.setBody(requestMsg);
  15.     
  16.     requestMsg.setJMSReplyTo(context.getReplyToDestination());
  17.     
  18.     return msg;
  19.   } catch (JMSException e) {
  20.     throw new JMSBindingException(e);
  21.   } 
  22. }

代码示例来源：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-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. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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