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

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

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

Message.setHeader介绍

暂无

代码示例

代码示例来源：origin: deeplearning4j/nd4j

  1. @Override
  2.   public void process(Exchange exchange) throws Exception {
  3.     final INDArray arr = (INDArray) exchange.getIn().getBody();
  4.     ByteArrayOutputStream bos = new ByteArrayOutputStream();
  5.     DataOutputStream dos = new DataOutputStream(bos);
  6.     Nd4j.write(arr, dos);
  7.     byte[] bytes = bos.toByteArray();
  8.     String base64 = Base64.encodeBase64String(bytes);
  9.     exchange.getIn().setBody(base64, String.class);
  10.     String id = UUID.randomUUID().toString();
  11.     exchange.getIn().setHeader(KafkaConstants.KEY, id);
  12.     exchange.getIn().setHeader(KafkaConstants.PARTITION_KEY, id);
  13.   }
  14. }).to(kafkaUri);

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

  1. private void setResult(Message message, boolean success, Object result, Object oldValue) {
  2.     message.setHeader(CaffeineConstants.ACTION_SUCCEEDED, success);
  3.     message.setHeader(CaffeineConstants.ACTION_HAS_RESULT, oldValue != null || result != null);
  5.     if (oldValue != null) {
  6.       message.setHeader(CaffeineConstants.OLD_VALUE, oldValue);
  7.     }
  8.     if (result != null) {
  9.       message.setBody(result);
  10.     }
  11.   }
  12. }

代码示例来源：origin: io.syndesis.connector/connector-google-calendar

  1. private void beforeProducer(Exchange exchange) throws MessagingException, IOException, ParseException {
  2.   final Message in = exchange.getIn();
  3.   in.setHeader("CamelGoogleCalendar.eventId", eventId);
  4.   in.setHeader("CamelGoogleCalendar.calendarId", calendarId);
  5. }

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

  1. /**
  2.  * A strategy method to populate an exchange with some example values for use
  3.  * by language plugins
  4.  */
  5. protected void populateExchange(Exchange exchange) {
  6.   Message in = exchange.getIn();
  7.   in.setHeader("foo", "abc");
  8.   in.setHeader("bar", 123);
  9.   in.setBody("<hello id='m123'>world!</hello>");
  10. }

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

  1. /**
  2.  * Writes the flow id to the contained {@link Exchange}.
  3.  * 
  4.  * @param flowId
  5.  *            flow identifier.
  6.  */
  7. @Override
  8. public void setFlowId(Long flowId) {
  9.   exchange.getIn().setHeader(FLOW_ID_KEY, flowId);
  10. }

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

  1. private void setResult(Message message, boolean success, Object result, Object oldValue) {
  2.     message.setHeader(CaffeineConstants.ACTION_SUCCEEDED, success);
  3.     message.setHeader(CaffeineConstants.ACTION_HAS_RESULT, oldValue != null || result != null);
  5.     if (oldValue != null) {
  6.       message.setHeader(CaffeineConstants.OLD_VALUE, oldValue);
  7.     }
  8.     if (result != null) {
  9.       message.setBody(result);
  10.     }
  11.   }
  12. }

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

  1. public void process(Exchange exchange) {
  2.     Message in = exchange.getIn();
  3.     in.setBody(body);
  4.     for (Map.Entry<String, Object> entry : headers.entrySet()) {
  5.       in.setHeader(entry.getKey(), entry.getValue());
  6.     }
  7.   }
  8. });

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

  1. public static void setListenerHeaders(Exchange ex, String listenerType, String listenerAction) {
  2.   ex.getIn().setHeader(HazelcastConstants.LISTENER_ACTION, listenerAction);
  3.   ex.getIn().setHeader(HazelcastConstants.LISTENER_TYPE, listenerType);
  4.   ex.getIn().setHeader(HazelcastConstants.LISTENER_TIME, new Date().getTime());
  5. }

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

  1. protected void setBodyAndResult(Message message, Object body, boolean result) throws Exception {
  2.   message.setHeader(ConsulConstants.CONSUL_RESULT, result);
  3.   if (body != null) {
  4.     message.setBody(body);
  5.   }
  6. }

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

  1. /**
  2.  * Creates an exchange with the given body
  3.  */
  4. protected Exchange createExchangeWithBody(CamelContext camelContext, Object body) {
  5.   Exchange exchange = new DefaultExchange(camelContext);
  6.   Message message = exchange.getIn();        
  7.   message.setHeader("testClass", getClass().getName());
  8.   message.setBody(body);
  9.   return exchange;
  10. }

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

  1. @Override
  2. public void process(Exchange exchange) {
  3.   if (exchange == null) return;
  4.   exchange.getIn().setHeader(Exchange.HTTP_PATH, path);
  5.   logger.debug("Setting HTTP path to {}", path);
  6. }

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

  1. private void setResult(Message message, Object result) {
  2.     String resultHeader = message.getHeader(InfinispanConstants.RESULT_HEADER, configuration::getResultHeader, String.class);
  3.     if (resultHeader != null) {
  4.       message.setHeader(resultHeader, result);
  5.     } else {
  6.       message.setBody(result);
  7.     }
  8.   }
  9. }

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

  1. /**
  2.  * Creates an exchange with the given body
  3.  */
  4. protected Exchange createExchangeWithBody(CamelContext camelContext, Object body) {
  5.   Exchange exchange = new DefaultExchange(camelContext);
  6.   Message message = exchange.getIn();
  7.   message.setHeader("testName", getName());
  8.   message.setHeader("testClass", getClass().getName());
  9.   message.setBody(body);
  10.   return exchange;
  11. }

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

  1. @Override
  2.   public void process(Exchange exchange) throws Exception {
  3.     logger.debug("Setting Content-Type header to {}", contentType);
  4.     exchange.getIn().setHeader(Exchange.CONTENT_TYPE, contentType);
  5.   }
  6. }

代码示例来源：origin: org.metaeffekt.dcc/dcc-agent-core

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. protected void doHandleFailedExchange(Exchange exchange, Throwable t) {
  5.   final int errorCode = mapToHttpErrorCode(t);
  6.   exchange.getOut().setBody(String.format("Exception [%s] occured. Message was [%s]", t.getClass().getName(), t.getMessage()));
  7.   exchange.getOut().setHeader(Exchange.HTTP_RESPONSE_CODE, (int) errorCode);
  8. }

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

  1. public Exchange createMongoDbExchange(DBObject dbObj) {
  2.   Exchange exchange = super.createExchange();
  3.   Message message = exchange.getIn();
  4.   message.setHeader(MongoDbConstants.DATABASE, database);
  5.   message.setHeader(MongoDbConstants.COLLECTION, collection);
  6.   message.setHeader(MongoDbConstants.FROM_TAILABLE, true);
  7.   message.setBody(dbObj);
  8.   return exchange;
  9. }

代码示例来源：origin: org.apache.camel/camel-example-loan-broker

  1. public void process(Exchange exchange) throws Exception {
  2.   String ssn = exchange.getIn().getHeader(Constants.PROPERTY_SSN, String.class);
  3.   int score = (int) (Math.random() * 600 + 300);
  4.   int hlength = (int) (Math.random() * 19 + 1);
  5.   exchange.getOut().setHeader(Constants.PROPERTY_SCORE, score);
  6.   exchange.getOut().setHeader(Constants.PROPERTY_HISTORYLENGTH, hlength);
  7.   exchange.getOut().setHeader(Constants.PROPERTY_SSN, ssn);
  8. }

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

  1. private void processAndTransferResult(Object result, Exchange exchange, MongoDbOperation operation) {
  2.   // determine where to set the WriteResult: as the OUT body or as an IN message header
  3.   if (isWriteOperation(operation) && endpoint.isWriteResultAsHeader()) {
  4.     exchange.getOut().setHeader(MongoDbConstants.WRITERESULT, result);
  5.   } else {
  6.     exchange.getOut().setBody(result);
  7.   }
  8. }

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

  1. public Exchange createExchange(String seq, String id, JsonObject obj, boolean deleted) {
  2.   Exchange exchange = super.createExchange();
  3.   exchange.getIn().setHeader(CouchDbConstants.HEADER_DATABASE, database);
  4.   exchange.getIn().setHeader(CouchDbConstants.HEADER_SEQ, seq);
  5.   exchange.getIn().setHeader(CouchDbConstants.HEADER_DOC_ID, id);
  6.   exchange.getIn().setHeader(CouchDbConstants.HEADER_DOC_REV, obj.get("_rev").getAsString());
  7.   exchange.getIn().setHeader(CouchDbConstants.HEADER_METHOD, deleted ? "DELETE" : "UPDATE");
  8.   exchange.getIn().setBody(obj);
  9.   return exchange;
  10. }

代码示例来源：origin: OpenNMS/opennms

  1. @Override
  2.   public void postProcess(Exchange exchange) {
  3.     // Copy the value of the correlation id header from the in to the out
  4.     exchange.getOut().setHeader(AmazonSQSRPCConstants.AWS_SQS_CORRELATION_ID_HEADER,
  5.         exchange.getIn().getHeader(AmazonSQSRPCConstants.AWS_SQS_CORRELATION_ID_HEADER));
  6.   }
  7. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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