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

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

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

Message.getHeader介绍

暂无

代码示例

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

  1. public void process(Exchange exchange) throws Exception {
  2.   String bankName = exchange.getIn().getHeader(Constants.PROPERTY_BANK, String.class);
  3.   String ssn = exchange.getIn().getHeader(Constants.PROPERTY_SSN, String.class);
  4.   Double rate = exchange.getIn().getHeader(Constants.PROPERTY_RATE, Double.class);
  5.   String answer = "The best rate is [ssn:" + ssn + " bank:" + bankName + " rate:" + rate + "]";
  6.   exchange.getOut().setBody(answer);
  7. }

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

  1. public void process(Exchange exchange) throws Exception {
  2.     System.out.println("Production received order: "
  3.         + exchange.getIn().getHeader("CamelFileName"));  
  4.   }
  5. });

代码示例来源：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. }

代码示例来源：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.ojbc.bundles.prototypes.shared/Bundle_Integration_Test_Common

  1. public void appendMessage(Exchange e) throws Exception {
  2.   
  3.   Message m = e.getIn();
  4.   
  5.   String s = m.getHeader("s", String.class);
  6.   
  7.   String body = m.getBody(String.class);
  8.   m.setBody(body + "\n" + s);
  9.   
  10. }

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

  1. protected void writeRequestHeaders(GHttpEndpoint endpoint, Exchange exchange, HTTPRequest request) {
  2.   HeaderFilterStrategy strategy = endpoint.getHeaderFilterStrategy();
  3.   for (String headerName : exchange.getIn().getHeaders().keySet()) {
  4.     String headerValue = exchange.getIn().getHeader(headerName, String.class);
  5.     if (strategy != null && !strategy.applyFilterToCamelHeaders(headerName, headerValue, exchange)) {
  6.       request.addHeader(new HTTPHeader(headerName, headerValue));
  7.     }
  8.   }
  9. }

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

  1. public void process(Exchange exchange) throws Exception {
  2.   String operationName = exchange.getIn().getHeader(CxfConstants.OPERATION_NAME, String.class);
  3.   Method method = findMethod(operationName, exchange.getIn().getBody(Object[].class));
  4.   try {
  5.     Object response = method.invoke(instance, exchange.getIn().getBody(Object[].class));
  6.     exchange.getOut().setBody(response);
  7.   }  catch (InvocationTargetException e) {
  8.     throw (Exception)e.getCause();
  9.   }
  10. }

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

  1. public void process(Exchange exchange) throws Exception {
  2.     System.out.println("Accounting received order: "
  3.         + exchange.getIn().getHeader("CamelFileName"));  
  4.   }
  5. });

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

  1. @SuppressWarnings("unchecked")
  2. private void doSize(Message in, Message out) {
  3.   Object peekMode = in.getHeader(IgniteConstants.IGNITE_CACHE_PEEK_MODE, endpoint.getCachePeekMode());
  4.   Integer result = null;
  5.   if (peekMode instanceof Collection) {
  6.     result = cache.size(((Collection<Object>) peekMode).toArray(new CachePeekMode[0]));
  7.   } else if (peekMode instanceof CachePeekMode) {
  8.     result = cache.size((CachePeekMode) peekMode);
  9.   }
  10.   out.setBody(result);
  11. }

代码示例来源：origin: org.ojbc.bundles.shared/ojb-fedquery-common

  1. @SuppressWarnings("unchecked")
  2. public void updateExchange(Exchange groupedExchange)
  3. {        
  4.   List<Exchange> exchangeList = groupedExchange.getProperty(Exchange.GROUPED_EXCHANGE, List.class);
  6.   if (exchangeList.size() == 1)
  7.   {
  8.     Exchange orignalBookingExchange = exchangeList.get(0);
  9.     
  10.     String federatedQueryGUID = (String) orignalBookingExchange.getIn().getHeader("federatedQueryRequestGUID");
  11.     groupedExchange.getIn().setBody(orignalBookingExchange.getIn().getHeader("requestMessageBody"));
  12.     groupedExchange.getIn().setHeader("federatedQueryRequestGUID", federatedQueryGUID);
  13.   }    
  14. }

代码示例来源：origin: org.opennms.core.ipc.rpc/org.opennms.core.ipc.rpc.aws-sqs-impl

  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. }

代码示例来源：origin: Simba-cheng/ApacheCamelDemo

  1. @Override
  2. public void process(Exchange exchange) throws Exception {
  3.   String inputMessage = exchange.getIn().getBody(String.class);
  4.   LOGGER.info("inputMessage : " + inputMessage);
  5.   String operationName = exchange.getIn().getHeader(CxfConstants.OPERATION_NAME, String.class);
  6.   Method method = findMethod(operationName, exchange.getIn().getBody(Object[].class));
  7.   Object response = method.invoke(instance, exchange.getIn().getBody(Object[].class));
  8.   exchange.getOut().setBody(response);
  9. }

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

  1. public static String getLocalPath(DropboxConfiguration configuration, Exchange exchange) {
  2.   return ObjectHelper.isNotEmpty(
  3.     exchange.getIn().getHeader(DropboxConstants.HEADER_LOCAL_PATH))
  4.     ? exchange.getIn().getHeader(DropboxConstants.HEADER_LOCAL_PATH, String.class)
  5.     : configuration.getLocalPath();
  6. }

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

  1. @InvokeOnHeader(Web3jConstants.DB_PUT_HEX)
  2. void dbPutHex(Message message) throws IOException {
  3.   String databaseName = message.getHeader(Web3jConstants.DATABASE_NAME, configuration::getDatabaseName, String.class);
  4.   String keyName = message.getHeader(Web3jConstants.KEY_NAME, configuration::getKeyName, String.class);
  5.   Request<?, DbPutHex> request = web3j.dbPutHex(databaseName, keyName, message.getBody(String.class));
  6.   setRequestId(message, request);
  7.   DbPutHex response = request.send();
  8.   boolean hasError = checkForError(message, response);
  9.   if (!hasError) {
  10.     message.setBody(response.valueStored());
  11.   }
  12. }

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

  1. @Override
  2.   void execute(Cache<Object, Object> cache, Exchange exchange) {
  3.     exchange.getIn().setBody(
  4.       cache.getAndReplace(
  5.         exchange.getIn().getHeader(JCacheConstants.KEY),
  6.         exchange.getIn().getBody())
  7.     );
  8.   }
  9. },

代码示例来源：origin: org.fusesource.bai/bai-core

  1. protected String getBreadCrumbId(Exchange source) {
  2.   String bid = source.getIn().getHeader(Exchange.BREADCRUMB_ID, String.class);
  3.   if (bid == null && source.hasOut()) {
  4.     bid = source.getOut().getHeader(Exchange.BREADCRUMB_ID, String.class);
  5.   }
  6.   return bid;
  7. }

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

  1. private void restoreDroplet(Exchange exchange) throws Exception {
  2.   if (ObjectHelper.isEmpty(exchange.getIn().getHeader(DigitalOceanHeaders.IMAGE_ID))) {
  3.     throw new IllegalArgumentException(DigitalOceanHeaders.IMAGE_ID + " must be specified");
  4.   }
  5.   Action action = getEndpoint().getDigitalOceanClient().restoreDroplet(dropletId, exchange.getIn().getHeader(DigitalOceanHeaders.IMAGE_ID, Integer.class));
  6.   LOG.trace("DropletAction Restore [{}] ", action);
  7.   exchange.getOut().setBody(action);
  8. }

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

  1. // Note: Content Type - might need treatment!
  2. public class AttachmentAttacher{
  3.   public void process(Exchange exchange){
  4.    Message in = exchange.getIn();
  5.    byte[] file = in.getBody(byte[].class);
  6.    String fileId = in.getHeader("CamelFileName",String.class);
  7.    in.addAttachment(fileId, new DataHandler(file,"plain/text"));
  8.   }
  9. }

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

  1. @InvokeOnHeader(Web3jConstants.ETH_SIGN)
  2. void ethSign(Message message) throws IOException {
  3.   String address = message.getHeader(Web3jConstants.ADDRESS, configuration::getAddress, String.class);
  4.   String sha3HashOfDataToSign = message.getHeader(Web3jConstants.SHA3_HASH_OF_DATA_TO_SIGN, configuration::getSha3HashOfDataToSign, String.class);
  5.   Request<?, EthSign> request = web3j.ethSign(address, sha3HashOfDataToSign);
  6.   setRequestId(message, request);
  7.   EthSign response = request.send();
  8.   boolean hasError = checkForError(message, response);
  9.   if (!hasError) {
  10.     message.setBody(response.getSignature());
  11.   }
  12. }

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

  1. @Override
  2.   void execute(Cache<Object, Object> cache, Exchange exchange) {
  3.     exchange.getIn().setBody(
  4.       cache.getAndPut(
  5.         exchange.getIn().getHeader(JCacheConstants.KEY),
  6.         exchange.getIn().getBody())
  7.     );
  8.   }
  9. },

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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