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

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

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

Message.getAttachments介绍

暂无

代码示例

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

  1. /**
  2.  * Populate SOAP attachments from in or out exchange message. This the
  3.  * convenient method for overriding.
  4.  * 
  5.  * @param inOrOut
  6.  * @param response
  7.  */
  8. protected void doProcessSoapAttachments(Message inOrOut, SoapMessage response) {
  9.   Map<String, DataHandler> attachments = inOrOut.getAttachments();
  10.   Set<String> keySet = new HashSet<>(attachments.keySet());
  11.   for (String key : keySet) {
  12.     response.addAttachment(key, attachments.get(key));
  13.   }
  14. }

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

  1. /**
  2.  * Populates message attachments from soap response attachments 
  3.  * @param inOrOut {@link Message}
  4.  * @param soapMessage {@link SoapMessage}
  5.  */
  6. private void populateMessageAttachmentsFromResponse(Message inOrOut, Iterator<Attachment> attachments) {
  7.   while (attachments.hasNext()) {
  8.     Attachment attachment = attachments.next();
  9.     inOrOut.getAttachments().put(attachment.getContentId(), attachment.getDataHandler());
  10.   }
  11. }

代码示例来源：origin: OpenWiseSolutions/openhub-framework

  1. /**
  2.  * Propagates (copies) the {@code Body}, the {@code Attachments} and the {@code Headers} of the {@link Message}
  3.  * from from IN to OUT.
  4.  *
  5.  * @param exchange the exchange message
  6.  */
  7. public static void propagateMessage(Exchange exchange) {
  8.   Assert.notNull(exchange, "the exchange must not be null");
  9.   // copy headers from IN to OUT to propagate them
  10.   exchange.getOut().setHeaders(exchange.getIn().getHeaders());
  11.   // copy attachments from IN to OUT to propagate them
  12.   exchange.getOut().setAttachments(exchange.getIn().getAttachments());
  13.   // copy body from IN to OUT to propagate it
  14.   exchange.getOut().setBody(exchange.getIn().getBody());
  15. }

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

  1. @Override
  2. public Object evaluate(Exchange exchange) {
  3.   // must use getAttachments to ensure attachments is initial populated
  4.   if (exchange.getIn().getAttachments().isEmpty()) {
  5.     return null;
  6.   }
  7.   try {
  8.     List<Message> answer = new ArrayList<>();
  9.     Message inMessage = exchange.getIn();
  10.     for (Map.Entry<String, Attachment> entry : inMessage.getAttachmentObjects().entrySet()) {
  11.       Message attachmentMessage;
  12.       if (extractAttachments) {
  13.         attachmentMessage = extractAttachment(inMessage, entry.getKey());
  14.       } else {
  15.         attachmentMessage = splitAttachment(inMessage, entry.getKey(), entry.getValue());
  16.       }
  17.       if (attachmentMessage != null) {
  18.         answer.add(attachmentMessage);
  19.       }
  20.     }
  21.     return answer;
  22.   } catch (Exception e) {
  23.     throw new RuntimeCamelException("Unable to split attachments from MimeMultipart message", e);
  24.   }
  25. }

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

  1. public void process(Exchange exchange) throws Exception {
  2.   String filter = exchange.getIn().getBody(String.class);
  3.   DirContext dirContext = getDirContext();
  4.   try {
  5.     // could throw NamingException
  6.     List<SearchResult> data;
  7.     if (pageSize == null) {
  8.       data = simpleSearch(dirContext, filter);
  9.     } else {
  10.       if (!(dirContext instanceof LdapContext)) {
  11.         throw new IllegalArgumentException("When using attribute 'pageSize' for a ldap endpoint, you must provide a LdapContext (subclass of DirContext)");
  12.       }
  13.       data = pagedSearch((LdapContext) dirContext, filter);
  14.     }
  15.     exchange.getOut().setBody(data);
  16.     exchange.getOut().setHeaders(exchange.getIn().getHeaders());
  17.     exchange.getOut().setAttachments(exchange.getIn().getAttachments());
  18.   } finally {
  19.     if (dirContext != null) {
  20.       dirContext.close();
  21.     }
  22.   }
  23. }

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

  1. @Override
  2. public void process(Exchange exchange) throws Exception {
  3.   TikaOperation operation = this.tikaConfiguration.getOperation();
  4.   Object result;
  5.   switch (operation) {
  6.   case detect:
  7.     result = doDetect(exchange);
  8.     break;
  9.   case parse:
  10.     result = doParse(exchange);
  11.     break;
  12.   default:
  13.     throw new IllegalArgumentException(String.format("Unknown operation %s", tikaConfiguration.getOperation()));
  14.   }
  15.   // propagate headers
  16.   exchange.getOut().setHeaders(exchange.getIn().getHeaders());
  17.   exchange.getOut().setAttachments(exchange.getIn().getAttachments());
  18.   // and set result
  19.   exchange.getOut().setBody(result);
  20. }

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

  1. @Override
  2. public void process(Exchange exchange) throws Exception {
  3.   Object result;
  4.   switch (pdfConfiguration.getOperation()) {
  5.   case append:
  6.     result = doAppend(exchange);
  7.     break;
  8.   case create:
  9.     result = doCreate(exchange);
  10.     break;
  11.   case extractText:
  12.     result = doExtractText(exchange);
  13.     break;
  14.   default:
  15.     throw new IllegalArgumentException(String.format("Unknown operation %s", pdfConfiguration.getOperation()));
  16.   }
  17.   // propagate headers
  18.   exchange.getOut().setHeaders(exchange.getIn().getHeaders());
  19.   exchange.getOut().setAttachments(exchange.getIn().getAttachments());
  20.   // and set result
  21.   exchange.getOut().setBody(result);
  22. }

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

  1. exchange.getOut().setAttachments(exchange.getIn().getAttachments());
  2.   exchange.getOut().setBody(dataStore.get(key));
  3. } else if (KratiConstants.KRATI_OPERATION_DELETE.equals(operation) && key != null) {
  4.     exchange.getOut().setAttachments(exchange.getIn().getAttachments());
  5.     exchange.getOut().setHeader(KratiConstants.KRATI_OPERATION_STATUS, KratiConstants.KRATI_OPERATION_SUCESSFUL);
  6.   } else {
  7.     exchange.getOut().setHeaders(exchange.getIn().getHeaders());
  8.     exchange.getOut().setAttachments(exchange.getIn().getAttachments());
  9.     exchange.getOut().setHeader(KratiConstants.KRATI_OPERATION_STATUS, KratiConstants.KRATI_OPERATION_FAILURE);
  10.     dataStore.clear();
  11.     exchange.getOut().setHeaders(exchange.getIn().getHeaders());
  12.     exchange.getOut().setAttachments(exchange.getIn().getAttachments());
  13.     exchange.getOut().setHeader(KratiConstants.KRATI_OPERATION_STATUS, KratiConstants.KRATI_OPERATION_SUCESSFUL);
  14.   } catch (Exception e) {

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

  1. @Override
  2. protected void onExchange(Exchange exchange) throws Exception {
  3.   String newResourceUri = exchange.getIn().getHeader(MUSTACHE_RESOURCE_URI, String.class);
  4.   if (newResourceUri == null) {
  5.     // Get Mustache
  6.     String newTemplate = exchange.getIn().getHeader(MUSTACHE_TEMPLATE, String.class);
  7.     Mustache newMustache;
  8.     if (newTemplate == null) {
  9.       newMustache = getOrCreateMustache();
  10.     } else {
  11.       newMustache = createMustache(new StringReader(newTemplate), "mustache:temp#" + newTemplate.hashCode());
  12.       exchange.getIn().removeHeader(MUSTACHE_TEMPLATE);
  13.     }
  14.     // Execute Mustache
  15.     Map<String, Object> variableMap = ExchangeHelper.createVariableMap(exchange);
  16.     StringWriter writer = new StringWriter();
  17.     newMustache.execute(writer, variableMap);
  18.     writer.flush();
  19.     // Fill out message
  20.     Message out = exchange.getOut();
  21.     out.setBody(writer.toString());
  22.     out.setHeaders(exchange.getIn().getHeaders());
  23.     out.setAttachments(exchange.getIn().getAttachments());
  24.   } else {
  25.     exchange.getIn().removeHeader(MustacheConstants.MUSTACHE_RESOURCE_URI);
  26.     MustacheEndpoint newEndpoint = getCamelContext().getEndpoint(MUSTACHE_ENDPOINT_URI_PREFIX + newResourceUri, MustacheEndpoint.class);
  27.     newEndpoint.onExchange(exchange);
  28.   }
  29. }

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

  1. @Override
  2.   protected void onExchange(Exchange exchange) throws Exception {
  3.     StringWriter buffer = new StringWriter();
  4.     
  5.     @SuppressWarnings("unchecked")
  6.     Map<String, Object> variableMap = exchange.getIn().getHeader(StringTemplateConstants.STRINGTEMPLATE_VARIABLE_MAP, Map.class);
  7.     if (variableMap == null) {
  8.       variableMap = ExchangeHelper.createVariableMap(exchange);
  9.     }
  11.     // getResourceAsInputStream also considers the content cache
  12.     String text = exchange.getContext().getTypeConverter().mandatoryConvertTo(String.class, getResourceAsInputStream());
  13.     ST template = new ST(text, delimiterStart, delimiterStop);
  14.     for (Map.Entry<String, Object> entry : variableMap.entrySet()) {
  15.       template.add(entry.getKey(), entry.getValue());
  16.     }
  17.     log.debug("StringTemplate is writing using attributes: {}", variableMap);
  18.     template.write(new NoIndentWriter(buffer));
  20.     // now lets output the results to the exchange
  21.     Message out = exchange.getOut();
  22.     out.setBody(buffer.toString());
  23.     out.setHeaders(exchange.getIn().getHeaders());
  24.     out.setHeader(StringTemplateConstants.STRINGTEMPLATE_RESOURCE_URI, getResourceUri());
  25.     out.setAttachments(exchange.getIn().getAttachments());
  26.   }
  27. }

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

  1. exchange.getIn().getBody();
  2. exchange.getIn().getHeaders();
  3. exchange.getIn().getAttachments();

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

  1. @Override
  2.   public void process(Exchange exchange) throws Exception {
  3.     final Message in = exchange.getIn();
  4.     String command = in.getMandatoryBody(String.class);
  6.     final Map<String, Object> headers = exchange.getIn().getHeaders();
  8.     try {
  9.       String knownHostResource = endpoint.getKnownHostsResource();
  10.       if (knownHostResource != null) {
  11.         client.setServerKeyVerifier(new ResourceBasedSSHKeyVerifier(exchange.getContext(), knownHostResource,
  12.             endpoint.isFailOnUnknownHost()));
  13.       }
  14.       SshResult result = SshHelper.sendExecCommand(headers, command, endpoint, client);
  15.       exchange.getOut().setBody(result.getStdout());
  16.       exchange.getOut().setHeader(SshResult.EXIT_VALUE, result.getExitValue());
  17.       exchange.getOut().setHeader(SshResult.STDERR, result.getStderr());
  18.     } catch (Exception e) {
  19.       throw new CamelExchangeException("Cannot execute command: " + command, exchange, e);
  20.     }
  22.     // propagate headers and attachments
  23.     exchange.getOut().getHeaders().putAll(in.getHeaders());
  24.     exchange.getOut().setAttachments(in.getAttachments());
  25.   }
  26. }

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

  1. out.setBody(newChunk.toString());
  2.   out.setHeaders(exchange.getIn().getHeaders());
  3.   out.setAttachments(exchange.getIn().getAttachments());
  4. } else {
  5.   exchange.getIn().removeHeader(ChunkConstants.CHUNK_RESOURCE_URI);

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

  1. for (Entry<String, DataHandler> entry : sourceMessage.getAttachments().entrySet()) {
  2.   message.addAttachment(entry.getKey(), entry.getValue().getDataSource());

代码示例来源：origin: io.atlasmap/camel-atlasmap

  1. private void populateTargetDocuments(AtlasSession session, Exchange exchange) {
  2.   Message outMessage = exchange.getOut();
  3.   outMessage.setHeaders(exchange.getIn().getHeaders());
  4.   outMessage.setAttachments(exchange.getIn().getAttachments());

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

  1. for (Entry<String, DataHandler> entry : sourceMessage.getAttachments().entrySet()) {
  2.   message.addAttachment(entry.getKey(), entry.getValue().getDataSource());

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

  1. out.setBody(result.toString());
  2. out.setHeaders(exchange.getIn().getHeaders());
  3. out.setAttachments(exchange.getIn().getAttachments());

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

  1. @Override
  2. public void copyFrom(org.apache.camel.Message that) {
  3.   if (that == this) {
  4.     // the same instance so do not need to copy
  5.     return;
  6.   }
  7.   if (that instanceof CamelContextAware) {
  8.     this.setCamelContext(((CamelContextAware) that).getCamelContext());
  9.   }
  10.   // cover over exchange if none has been assigned
  11.   if (getExchange() == null) {
  12.     setExchange(that.getExchange());
  13.   }
  14.   setMessageId(that.getMessageId());
  15.   setBody(that.getBody());
  16.   super.getHeaders().putAll(that.getHeaders());
  17.   if (that instanceof SpringIntegrationMessage) {
  18.     SpringIntegrationMessage orig = (SpringIntegrationMessage) that;
  19.     setMessage(orig.getMessage());
  20.   }
  21.   getAttachments().putAll(that.getAttachments());
  22. }

代码示例来源：origin: org.milyn/milyn-smooks-all

  1. exchange.getOut().setAttachments(exchange.getIn().getAttachments());

代码示例来源：origin: org.dhatim/milyn-smooks-camel

  1. exchange.getOut().setAttachments(exchange.getIn().getAttachments());

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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