org.apache.camel.Message.copyFromWithNewBody()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(1.9k)|赞(0)|评价(0)|浏览(190)

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

Message.copyFromWithNewBody介绍

暂无

代码示例

代码示例来源:origin: org.apache.camel/camel-spring-ws

  1. @Override
  2. public void doWithMessage(WebServiceMessage responseMessage) throws IOException, TransformerException {
  3. SoapMessage soapMessage = (SoapMessage) responseMessage;
  4. if (ExchangeHelper.isOutCapable(exchange)) {
  5. exchange.getOut().copyFromWithNewBody(exchange.getIn(), soapMessage.getPayloadSource());
  6. populateHeaderAndAttachmentsFromResponse(exchange.getOut(), soapMessage);
  7. } else {
  8. exchange.getIn().setBody(soapMessage.getPayloadSource());
  9. populateHeaderAndAttachmentsFromResponse(exchange.getIn(), soapMessage);
  10. }
  11. }
  12. });

代码示例来源:origin: io.syndesis.connector/connector-support-processor

  1. @Override
  2. public void process(Exchange exchange) throws Exception {
  3. final Message message = exchange.getIn();
  4. final Object body = message.getBody();
  5. final ObjectNode rootNode = Json.copyObjectMapperConfiguration().createObjectNode();
  6. if (!parameters.isEmpty()) {
  7. final ObjectNode parametersNode = rootNode.putObject("parameters");
  8. for (String parameter : parameters) {
  9. parametersNode.put(parameter, message.getHeader(parameter, String.class));
  10. }
  11. }
  12. if (body instanceof String) {
  13. final String string = (String) body;
  14. if (ObjectHelper.isNotEmpty(string)) {
  15. rootNode.set("body", READER.readValue(string));
  16. }
  17. } else if (body instanceof InputStream) {
  18. try (InputStream stream = (InputStream) body) {
  19. if (stream.available() > 0) {
  20. rootNode.set("body", READER.readValue(stream));
  21. }
  22. }
  23. } else if (body != null) {
  24. rootNode.putPOJO("body", body);
  25. }
  26. final String newBody = Json.toString(rootNode);
  27. final Message replacement = new DefaultMessage(exchange.getContext());
  28. replacement.copyFromWithNewBody(message, newBody);
  29. ExchangeHelper.replaceMessage(exchange, replacement, false);
  30. }

相关文章