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

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

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

Message.copy介绍

暂无

代码示例

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

private Message splitAttachment(Message inMessage, String attachmentName, Attachment attachmentHandler) {
  final Message copy = inMessage.copy();
  Map<String, Attachment> attachments = copy.getAttachmentObjects();
  attachments.clear();
  attachments.put(attachmentName, attachmentHandler);
  copy.setHeader(HEADER_NAME, attachmentName);
  return copy;
}

代码示例来源:origin: io.syndesis/integration-runtime

private void addToMap(Exchange exchange, String key, Message msg) {
  if( msg != null ) {
    Message copy = msg.copy();
    Map<String, Message> outMessagesMap = getCapturedMessageMap(exchange);
    outMessagesMap.put(key, copy);
  }
}

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

@Override
public void process(org.apache.camel.Exchange exchange) throws Exception {
  Message in = exchange.getIn();
  in.setHeader(OPERATION_SELECTOR_HEADER, _selector);
  exchange.setOut(in.copy());
}

代码示例来源:origin: org.switchyard.components/switchyard-component-common-camel

@Override
public void process(org.apache.camel.Exchange exchange) throws Exception {
  Message in = exchange.getIn();
  in.setHeader(MESSAGE_COMPOSER_HEADER, _composer);
  exchange.setOut(in.copy());
}

代码示例来源:origin: org.switchyard.components/switchyard-component-common-camel

@Override
public void process(org.apache.camel.Exchange exchange) throws Exception {
  Message in = exchange.getIn();
  in.setHeader(OPERATION_SELECTOR_HEADER, _selector);
  exchange.setOut(in.copy());
}

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

@Override
public void process(org.apache.camel.Exchange exchange) throws Exception {
  Message in = exchange.getIn();
  in.setHeader(MESSAGE_COMPOSER_HEADER, _composer);
  exchange.setOut(in.copy());
}

代码示例来源:origin: io.syndesis.integration/integration-runtime

@Override
public void process(Exchange exchange) throws Exception {
  final Message message = exchange.hasOut() ? exchange.getOut() : exchange.getIn();
  final String id = message.getHeader(IntegrationLoggingConstants.STEP_ID, String.class);
  if (id != null) {
    Message copy = message.copy();
    Map<String, Message> outMessagesMap = getCapturedMessageMap(exchange);
    if (copy instanceof MessageSupport && copy.getExchange() == null) {
      ((MessageSupport) copy).setExchange(message.getExchange());
    }
    outMessagesMap.put(id, copy);
  }
}

代码示例来源:origin: org.fusesource/camel-sap

exchange.setOut(exchange.getIn().copy());
exchange.getOut().setBody(response);

代码示例来源:origin: stackoverflow.com

message.add(currentMessage.copy());

相关文章