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

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

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

Message.getHeaders介绍

暂无

代码示例

代码示例来源：origin: org.openehealth.ipf.platform-camel/ipf-platform-camel-core

  1. @Override
  2. public <T> T evaluate(Exchange exchange, Class<T> type) {
  3.   return type.cast(exchange.getIn().getHeaders());
  4. }

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

  1. public void process(Exchange exchange) throws Exception {
  2.     Message in = exchange.getIn();
  3.     in.getHeaders().putAll(headers);
  4.     in.setBody(body);
  5.   }
  6. });

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

  1. protected Message getAnswerMessage(final Exchange exchange) {
  2.   Message answer = exchange.getIn();
  3.   if (ExchangeHelper.isOutCapable(exchange)) {
  4.     answer = exchange.getOut();
  5.     // preserve headers
  6.     answer.getHeaders().putAll(exchange.getIn().getHeaders());
  7.   }
  8.   return answer;
  9. }

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

  1. private Message resolveMessageFrom(final Exchange camelExchange) {
  2.   Message message = camelExchange.hasOut() ? camelExchange.getOut() : camelExchange.getIn();
  3.   // Remove the SERIALIZE_HEADER in case it was previously set
  4.   if (message.getHeaders() != null && message.getHeaders().containsKey(RabbitMQEndpoint.SERIALIZE_HEADER)) {
  5.     LOG.trace("Removing header: {}", RabbitMQEndpoint.SERIALIZE_HEADER);
  6.     message.getHeaders().remove(RabbitMQEndpoint.SERIALIZE_HEADER);
  7.   }
  8.   if (routingKey != null && routingKey.startsWith(RabbitMQConstants.RABBITMQ_DIRECT_REPLY_ROUTING_KEY)) {
  9.     message.setHeader(RabbitMQConstants.EXCHANGE_NAME, RabbitMQConstants.RABBITMQ_DIRECT_REPLY_EXCHANGE); // use default exchange for reply-to messages
  10.     message.setHeader(RabbitMQConstants.EXCHANGE_OVERRIDE_NAME, RabbitMQConstants.RABBITMQ_DIRECT_REPLY_EXCHANGE); // use default exchange for reply-to messages
  11.   }
  12.   return message;
  13. }

代码示例来源：origin: at.researchstudio.sat/won-core

  1. public void inspectHeaders(Exchange exchange){
  2.   Map headers = (Map) exchange.getIn().getHeaders();
  3.   Iterator iter =  headers.entrySet().iterator();
  4.   if (logger.isDebugEnabled()) {
  5.    logger.debug("WIRETAP: headers size: "+headers.size());
  6.    while(iter.hasNext()){
  7.      Map.Entry pairs = (Map.Entry)iter.next();
  8.      if(pairs.getValue()!=null)
  9.        logger.debug("key: "+pairs.getKey()+" value: "+pairs.getValue());
  10.    }
  11.   }
  12. }

代码示例来源：origin: opentelecoms-org/smsrouter

  1. @Override
  2. public boolean matches(Exchange exchange) {
  3.   Message message = exchange.getIn();
  4.   if(!message.getHeaders().containsKey(headerName)) {
  5.     return false;
  6.   }
  7.   String value = message.getHeader(headerName, String.class).toLowerCase();
  8.   if(tokens.contains(value)) {
  9.     logger.info("header '{}' value '{}' is blacklisted", headerName, value);
  10.     return true;
  11.   }
  12.   return false;
  13. }

代码示例来源：origin: org.openehealth.ipf.platform-camel/ipf-platform-camel-core

  1. @Override
  2. public <T> T evaluate(Exchange exchange, Class<T> type) {
  3.   Object[] result = new Object[2];
  4.   result [0] = exchange.getIn().getHeaders();
  5.   result [1] = MarkupBuilder.newInstance();
  6.   return type.cast(result);
  7. }

代码示例来源：origin: ru.yandex.qatools.camelot/camelot-commons

  1. @Override
  2. public Exchange preProcess(Exchange exchange, ClassLoader classLoader) {
  3.   final Object body = exchange.getIn().getBody();
  4.   if (body != null) {
  5.     exchange.getIn().setBody(processBodyAndHeadersAfterReceive(body, exchange.getIn().getHeaders(), classLoader));
  6.   }
  7.   return exchange;
  8. }

代码示例来源：origin: ru.yandex.qatools.camelot/camelot-commons

  1. @Override
  2. public Exchange postProcess(Exchange exchange, ClassLoader classLoader) {
  3.   final Object body = exchange.getIn().getBody();
  4.   if (body != null) {
  5.     exchange.getIn().setBody(processBodyAndHeadersBeforeSend(body, exchange.getIn().getHeaders(), classLoader));
  6.   }
  7.   return exchange;
  8. }

代码示例来源：origin: org.openehealth.ipf.platform-camel/ipf-platform-camel-ihe-fhir-pixpdq

  1. /**
  2.  * Returns a processor for translating FHIR messages to Hl7v2
  3.  * using the given translator instance. 
  4.  */
  5. public static Processor translatorFhirToHL7v2(final TranslatorFhirToHL7v2 translator) {
  6.   return exchange -> {
  7.     // ca.uhn.hl7v2.model.Message initial = exchange.getProperty(HL7V3_ORIGINAL_REQUEST_PROPERTY, ca.uhn.hl7v2.model.Message.class);
  8.     Object fhir = exchange.getIn().getBody();
  9.     Map<String, Object> parameters = exchange.getIn().getHeaders();
  10.     // exchange.setProperty(HL7V3_ORIGINAL_REQUEST_PROPERTY, xmlText);
  11.     org.apache.camel.Message resultMessage = Exchanges.resultMessage(exchange);
  12.     resultMessage.getHeaders().putAll(exchange.getIn().getHeaders());
  13.     resultMessage.setBody(translator.translateFhirToHL7v2(fhir, parameters));
  14.   };
  15. }

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

  1. /**
  2.  * Does the given camel message contain any To, CC or BCC header names?
  3.  */
  4. private static boolean hasRecipientHeaders(Exchange exchange) {
  5.   for (String key : exchange.getIn().getHeaders().keySet()) {
  6.     if (isRecipientHeader(key)) {
  7.       return true;
  8.     }
  9.   }
  10.   return false;
  11. }

代码示例来源：origin: nz.ac.auckland.morc/morc

  1. /**
  2.  * @param exchange The exchange containing the headers we need to validate
  3.  * @return true if each header in the test resource is in input; additional headers in the input will be ignored
  4.  */
  5. public boolean matches(Exchange exchange) {
  6.   Map<String, Object> value = exchange.getIn().getHeaders();
  7.   return matches(value);
  8. }

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

  1. public static org.springframework.messaging.Message<?> createSpringIntegrationMessage(Exchange exchange) {
  2.   return createSpringIntegrationMessage(exchange, exchange.getIn().getHeaders());
  3. }

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

  1. @Override
  2. public void onComplete(Object response) {
  3.   exchange.getOut().setHeaders(exchange.getIn().getHeaders());
  4.   if (response == null) {
  5.     exchange.getOut().setBody(response);
  6.   } else {
  7.     exchange.getOut().setBody(response, response.getClass());
  8.   }
  9.   callback.done(false);
  10. }

代码示例来源：origin: at.researchstudio.sat/won-node

  1. @Override
  2.  public void process(Exchange exchange) throws Exception {
  3.    logger.debug("processing messages for dynamic recipients generation");
  4.    Map headers = exchange.getIn().getHeaders();
  5.    Map properties = exchange.getProperties();
  6.    List<String> ownerApplications = (List<String>)headers.get(WonCamelConstants.OWNER_APPLICATIONS);
  7. //       String methodName =headers.get("methodName").toString();
  8.    logger.debug("number of registered owner applications: {}", ownerApplications == null ? 0 : ownerApplications.size());
  9.    List<String> queueNames = convertToQueueName(ownerApplications,"wonMessage",exchange);
  10.    exchange.getIn().setHeader("ownerApplicationIDs",queueNames);
  11.  }
  12.  private List<String> convertToQueueName(List<String> ownerApplications,String methodName,Exchange

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

  1. public static void setOut(Exchange exchange, Object payload) {
  2.   if (payload instanceof DefaultExchangeHolder) {
  3.     DefaultExchangeHolder.unmarshal(exchange, (DefaultExchangeHolder) payload);
  4.   } else {
  5.     // normal transfer using the body only and preserve the headers
  6.     exchange.getOut().setHeaders(exchange.getIn().getHeaders());
  7.     exchange.getOut().setBody(payload);
  8.   }
  9. }

代码示例来源：origin: camelinaction/camelinaction2

  1. public void process(Exchange exchange) throws Exception {
  2.   String input = exchange.getIn().getBody(String.class);
  3.   // if the verbose switch is turned on then log to System out
  4.   if (getEndpoint().isVerbose()) {
  5.     System.out.println("Calling ERP with: " + input);
  6.   }
  7.   // simulate calling ERP system and setting reply on the OUT body
  8.   exchange.getOut().setBody("Simulated response from ERP");
  9.   // support propagating headers (by copying headers from IN -> OUT)
  10.   exchange.getOut().setHeaders(exchange.getIn().getHeaders());
  11. }

代码示例来源：origin: camelinaction/camelinaction

  1. public void process(Exchange exchange) throws Exception {
  2.   String input = exchange.getIn().getBody(String.class);
  3.   // if the verbose switch is turned on then log to System out
  4.   if (getEndpoint().isVerbose()) {
  5.     System.out.println("Calling ERP with: " + input);
  6.   }
  7.   // simulate calling ERP system and setting reply on the OUT body
  8.   exchange.getOut().setBody("Simulated response from ERP");
  9.   // support propagating headers (by copying headers from IN -> OUT)
  10.   exchange.getOut().setHeaders(exchange.getIn().getHeaders());
  11. }

代码示例来源：origin: com.googlecode.metridoc/metridoc-camel-core

  1. @Override
  2. @SuppressWarnings("unchecked")
  3. public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
  4.   
  5.   if (oldExchange == null) {
  6.     oldExchange = new DefaultExchange(newExchange);
  7.     oldExchange.getIn().setHeaders(newExchange.getIn().getHeaders());
  8.     List<Object> body = new ArrayList<Object>();
  9.     oldExchange.getIn().setBody(body);
  10.     oldExchange.getExchangeId();
  11.   }
  12.   oldExchange.getIn().getBody(List.class).add(newExchange.getIn().getBody());
  13.   
  14.   return oldExchange;
  15. }

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

  1. @Override
  2. public void onResponse(Object response, Map<String, String> responseHeaders) {
  3.   // producer returns a single response, even for methods with List return types
  4.   exchange.getOut().setBody(response);
  5.   // copy headers
  6.   exchange.getOut().setHeaders(exchange.getIn().getHeaders());
  7.   
  8.   // Add http response headers
  9.   exchange.getOut().setHeader(Olingo2Constants.PROPERTY_PREFIX + RESPONSE_HTTP_HEADERS, responseHeaders);
  10.   interceptResult(response, exchange);
  11.   callback.done(false);
  12. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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