本文整理了Java中org.apache.camel.Message.copy()
方法的一些代码示例,展示了Message.copy()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Message.copy()
方法的具体详情如下:
包路径:org.apache.camel.Message
类名称: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());
内容来源于网络,如有侵权,请联系作者删除!