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

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

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

Message.setBody介绍

[英]Sets the body of the message.
[中]设置消息的正文。

代码示例

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

  1. public Message processRequest(Message msg) {
  2.   Map<String, Object> metadata = new HashMap<String, Object>();
  3.   metadata.put(Invocable.class.getName(), invocable);
  4.   Object input = mediator.mediateInput(msg.getBody(), sourceOperation, targetOperation, metadata);
  5.   msg.setBody(input);
  6.   return msg;
  7. }

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

  1. public Message processRequest(Message msg) {
  2.   Map<String, Object> metadata = new HashMap<String, Object>();
  3.   metadata.put(Invocable.class.getName(), invocable);
  4.   Object input = mediator.mediateInput(msg.getBody(), sourceOperation, targetOperation, metadata);
  5.   msg.setBody(input);
  6.   return msg;
  7. }

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

  1. public Message invoke(Message msg) {
  2.   try {
  3.     Object resp = invokeTarget(msg);
  4.     msg.setBody(resp);
  5.   } catch (InvocationTargetException e) {
  6.     msg.setFaultBody(e.getCause());
  7.   }
  8.   return msg;
  9. }

代码示例来源：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-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: com.jns.apps/scallop-binding-rmi-runtime

  1. public Message invoke(Message msg) {
  2.   try {
  3.     Object[] args = msg.getBody();
  4.     Object resp = invokeTarget(args);
  5.     msg.setBody(resp);
  6.   } catch (InvocationTargetException e) {
  7.     msg.setFaultBody(e.getCause());
  8.   } catch (Exception e) {
  9.     msg.setFaultBody(e);
  10.   }
  11.   return msg;
  12. }

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

  1. public Object invoke(Operation operation, Object[] args) throws InvocationTargetException {
  2.   Message msg = messageFactory.createMessage();
  3.   msg.setBody(args);
  4.   Message resp = invoke(operation, msg);
  5.   Object body = resp.getBody();
  6.   if (resp.isFault()) {
  7.     throw new InvocationTargetException((Throwable)body);
  8.   }
  9.   return body;
  10. }

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

  1. public Message invoke(Message msg) {
  2.   try {
  3.     Object[] args = msg.getBody();
  4.     Object resp = invokeTarget(args);
  5.     msg.setBody(resp);
  6.   } catch (InvocationTargetException e) {
  7.     msg.setFaultBody(e.getCause());
  8.   } catch (Throwable e) {
  9.     msg.setFaultBody(e);
  10.   }
  11.   return msg;
  12. }

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

  1. public Message invoke(Message msg) {
  2.   try {
  3.     Object[] args = msg.getBody();
  4.     Object resp = invokeTarget(args);
  5.     msg.setBody(resp);
  6.   } catch (InvocationTargetException e) {
  7.     msg.setFaultBody(e.getCause());
  8.   } catch (Throwable e) {
  9.     msg.setFaultBody(e);
  10.   }
  11.   return msg;
  12. }

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

  1. public Message doInvoke(Message msg) throws JsonGenerationException, JsonMappingException, IOException, EncoderException {
  2.   String uri = endpoint.getDeployedURI() + "/" + operation.getName();
  3.   //String[] jsonArgs = objectsToJSON((Object[])msg.getBody());
  4.   String[] jsonArgs = objectsToJSONStrings((Object[])msg.getBody());
  5.   String responseJSON = invokeHTTPRequest(uri, jsonArgs);
  6.   //Object response = jsonToObjects(responseJSON)[0];
  7.   msg.setBody(responseJSON);
  8.   return msg;
  9. }

代码示例来源：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-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 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-core-databinding

  1. public Message invoke(Message msg) {
  2.   if (chain.allowsPassByReference()) {
  3.     return nextInvoker.invoke(msg);
  4.   }
  5.   msg.setBody(mediator.copyInput(msg.getBody(), operation));
  6.   Message resultMsg = nextInvoker.invoke(msg);
  7.   if (!resultMsg.isFault() && operation.getOutputType() != null) {
  8.     resultMsg.setBody(mediator.copyOutput(resultMsg.getBody(), operation));
  9.   }
  10.   if (resultMsg.isFault()) {
  11.     resultMsg.setFaultBody(mediator.copyFault(resultMsg.getBody(), operation));
  12.   }
  13.   return resultMsg;
  14. }

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

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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