org.switchyard.Message.setContent()方法的使用及代码示例

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

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

Message.setContent介绍

[英]Assigns the specified content to the body of this message.
[中]将指定的内容分配给此邮件的正文。

代码示例

代码示例来源：origin: org.switchyard.components/switchyard-component-bean

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. @Override
  5. public Message setContent(Object content) {
  6.   return getMessage().setContent(content);
  7. }

代码示例来源：origin: jboss-switchyard/components

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. @Override
  5. public Message setContent(Object content) {
  6.   return getMessage().setContent(content);
  7. }

代码示例来源：origin: org.switchyard.components/switchyard-component-bean

  1. @Override
  2. public ReferenceInvocation invoke(Object content) throws Exception {
  3.   _inMessage.setContent(content);
  4.   return invoke();
  5. }

代码示例来源：origin: jboss-switchyard/components

  1. @Override
  2. public ReferenceInvocation invoke(Object content) throws Exception {
  3.   _inMessage.setContent(content);
  4.   return invoke();
  5. }

代码示例来源：origin: jboss-switchyard/components

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. @Override
  5. public org.switchyard.Message compose(MappedRecordBindingData source, Exchange exchange) throws Exception {
  6.   final org.switchyard.Message message = exchange.createMessage();
  7.   getContextMapper().mapFrom(source, exchange.getContext(message));
  8.   Map<Object,Object> m = new HashMap<Object,Object>();
  9.   m.putAll(source.getRecord());
  10.   message.setContent(m);
  11.   return message;
  12. }

代码示例来源：origin: jboss-switchyard/core

  1. @Override
  2.   public Message transform(Message message) {
  4.     try {
  5.       Object result = _mapper.readValue(message.getContent(Reader.class), _clazz);
  7.       if (_clazz.isInstance(result)) {
  8.         message.setContent(result);
  9.         return message;
  10.       } else {
  11.         throw TransformMessages.MESSAGES.transformationResultWrongType(result.getClass().toString());
  12.       }
  13.     } catch (JsonParseException e) {
  14.       throw TransformMessages.MESSAGES.unexpectedJSONParseException(e);
  15.     } catch (JsonMappingException e) {
  16.       throw TransformMessages.MESSAGES.unexpectedJSONMappingException(e);
  17.     } catch (IOException e) {
  18.       throw TransformMessages.MESSAGES.unexpectedIOExceptionCheckTransformer(e);
  19.     }
  20.   }
  21. }

代码示例来源：origin: jboss-switchyard/components

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. @Override
  5. public org.switchyard.Message compose(IndexedRecordBindingData source, Exchange exchange) throws Exception {
  6.   
  7.   final org.switchyard.Message message = exchange.createMessage();
  8.   getContextMapper().mapFrom(source, exchange.getContext(message));
  9.   List<Object> l = new ArrayList<Object>();
  10.   l.addAll(source.getRecord());
  11.   message.setContent(l);
  12.   return message;
  13. }

代码示例来源：origin: jboss-switchyard/components

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. @Override
  5. public Message compose(StreamableRecordBindingData source, Exchange exchange) throws Exception {
  6.   final org.switchyard.Message message = exchange.createMessage();
  7.   getContextMapper().mapFrom(source, exchange.getContext(message));
  8.   ByteArrayOutputStream baos = new ByteArrayOutputStream(); 
  9.   source.getRecord().write(baos);
  10.   message.setContent(new ByteArrayInputStream(baos.toByteArray()));
  11.   return message;
  12. }

代码示例来源：origin: jboss-switchyard/core

  1. @Override
  2.   public void handleMessage(Exchange exchange) throws HandlerException {
  3.     Message fault = exchange.createMessage();
  4.     fault.setContent(new Exception("testFaultTransformSequence"));
  5.     exchange.sendFault(fault);
  6.   }
  7. };

代码示例来源：origin: jboss-switchyard/core

  1. @Test
  2. public void testContent() throws Exception {
  3.   final String message = "Hello There!";
  4.   _message.setContent(message);
  5.   Assert.assertEquals(message, _message.getContent());
  6.   // the following tests to make sure casting to same type works
  7.   String content = _message.getContent(String.class);
  8.   Assert.assertEquals(message, content);
  9. }

代码示例来源：origin: jboss-switchyard/release

  1. @Override
  2. public org.switchyard.Message compose(JMSBindingData source, Exchange exchange) throws Exception {
  3.   org.switchyard.Message msg = super.compose(source, exchange);
  4.   msg.setContent(msg.getContent(String.class) + "test");
  5.   return msg;
  6. }

代码示例来源：origin: jboss-switchyard/components

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. @Override
  5. public Message compose(HttpBindingData source, Exchange exchange) throws Exception {
  6.   final Message message = exchange.createMessage();
  7.   getContextMapper().mapFrom(source, exchange.getContext(message));
  8.   QName msgType = getMessageType(exchange);
  9.   message.setContent(source.getBody());
  10.   Object content;
  11.   if ((msgType != null) && (QNameUtil.isJavaMessageType(msgType))) {
  12.     // Hack - the getContent() call triggers a conversion from native content type and the result is set as the new body
  13.     message.setContent(message.getContent(QNameUtil.toJavaMessageType(msgType)));
  14.   }
  15.   return message;
  16. }

代码示例来源：origin: org.switchyard.components/switchyard-component-http

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. @Override
  5. public Message compose(HttpBindingData source, Exchange exchange) throws Exception {
  6.   final Message message = exchange.createMessage();
  7.   getContextMapper().mapFrom(source, exchange.getContext(message));
  8.   QName msgType = getMessageType(exchange);
  9.   message.setContent(source.getBody());
  10.   Object content;
  11.   if ((msgType != null) && (QNameUtil.isJavaMessageType(msgType))) {
  12.     // Hack - the getContent() call triggers a conversion from native content type and the result is set as the new body
  13.     message.setContent(message.getContent(QNameUtil.toJavaMessageType(msgType)));
  14.   }
  15.   return message;
  16. }

代码示例来源：origin: jboss-switchyard/core

  1. public void handleMessage(Exchange exchange) {
  2.     Assert.assertEquals(
  3.         exchange.getMessage().getContent(), 
  4.         inMsgContent);
  5.     
  6.     Message outMsg = exchange.createMessage();
  7.     outMsg.setContent(outMsgContent);
  8.     try {
  9.       exchange.send(outMsg);
  10.     }
  11.     catch (Exception ex) {
  12.       Assert.fail(ex.toString());
  13.     }
  14.   }
  15. };

代码示例来源：origin: org.switchyard.components/switchyard-component-resteasy

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. @Override
  5. public Message compose(RESTEasyBindingData source, Exchange exchange) throws Exception {
  6.   final Message message = exchange.createMessage();
  7.   getContextMapper().mapFrom(source, exchange.getContext(message));
  8.   Object content = null;
  9.   if (source.getParameters().length > 0) {
  10.     content = source.getParameters()[0];
  11.   }
  12.   message.setContent(content);
  13.   return message;
  14. }

代码示例来源：origin: jboss-switchyard/release

  1. @Override
  2. public JMSBindingData decompose(Exchange exchange, JMSBindingData target) throws Exception {
  3.   exchange.getMessage().setContent(exchange.getMessage().getContent(String.class)+"test");
  4.   return super.decompose(exchange, target);
  5. }

代码示例来源：origin: jboss-switchyard/components

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. @Override
  5. public Message compose(RESTEasyBindingData source, Exchange exchange) throws Exception {
  6.   final Message message = exchange.createMessage();
  7.   getContextMapper().mapFrom(source, exchange.getContext(message));
  8.   Object content = null;
  9.   if (source.getParameters().length > 0) {
  10.     content = source.getParameters()[0];
  11.   }
  12.   message.setContent(content);
  13.   if (source.getParameters().length > 1) {
  14.     RestEasyLogger.ROOT_LOGGER.defaultRESTEasyMessageComposerDoesnTHandleMultipleInputParameters();
  15.   }
  16.   return message;
  17. }

代码示例来源：origin: jboss-switchyard/core

  1. @Test
  2. public void testStreamContent() throws Exception {
  3.   String contentAsString = "abc-InputStream-xyz";
  4.   MockHandler provider = new MockHandler();
  5.   _domain.getTransformerRegistry().addTransformer(new StreamTransformer());
  6.   ServiceReference service = _domain.createInOnlyService(new QName("StreamTest"), provider);
  7.   
  8.   InputStream contentAsStream = new ByteArrayInputStream(contentAsString.getBytes());
  9.   Exchange ex = service.createExchange();
  10.   Message msg = ex.createMessage();
  11.   msg.setContent(contentAsStream);
  12.   ex.send(msg);
  13.   Message rcvdMsg = provider.getMessages().poll().getMessage();
  14.   Assert.assertTrue(rcvdMsg.getContent(InputStream.class).available() > 0);
  15.   
  16. }

代码示例来源：origin: jboss-switchyard/core

  1. @Test
  2.   public void testReaderContent() throws Exception {
  3.     String contentAsString = "abc-Reader-xyz";
  4.     MockHandler provider = new MockHandler();
  5.     _domain.getTransformerRegistry().addTransformer(new ReaderTransformer());
  6.     ServiceReference service = _domain.createInOnlyService(new QName("ReaderTest"), provider);
  7.     
  8.     StringReader contentAsReader = new StringReader(contentAsString);
  9.     Exchange ex = service.createExchange();
  10.     Message msg = ex.createMessage();
  11.     msg.setContent(contentAsReader);
  12.     ex.send(msg);
  14.     Message rcvdMsg = provider.getMessages().poll().getMessage();
  15.     Assert.assertTrue(rcvdMsg.getContent(Reader.class).read() != -1);
  16.   }
  17. }

代码示例来源：origin: org.switchyard/switchyard-test

  1. /**
  2.  * Send an IN_ONLY message to the target Service.
  3.  * @param messagePayload The message payload.
  4.  * @throws InvocationFaultException if the message exchange produces a fault
  5.  */
  6. public void sendInOnly(Object messagePayload) throws InvocationFaultException {
  7.   ExchangeHandlerProxy exchangeHandlerProxy = _exchangeHandlerProxy;
  8.   ResponseCatcher responseCatcher = null;
  9.   if (exchangeHandlerProxy == null) {
  10.     responseCatcher = new ResponseCatcher();
  11.     exchangeHandlerProxy = createHandlerProxy(responseCatcher);
  12.   }
  13.   Exchange exchange = createExchange(ExchangePattern.IN_ONLY, exchangeHandlerProxy._exchangeHandlerProxy);
  14.   Message message = exchange.createMessage().setContent(messagePayload);
  15.   setProperties(exchange, message);
  16.   addAttachments(message);
  17.   exchange.send(message);
  18.   
  19.   if (exchange.getState().equals(ExchangeState.FAULT)) {
  20.     throw new InvocationFaultException(exchange.getMessage());
  21.   }
  22. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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