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

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

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

Message.setBody介绍

暂无

代码示例

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

  1. @Override
  2.   public void process(Exchange exchange) throws Exception {
  3.     byte[] body2 = (byte[]) exchange.getIn().getBody();
  4.     String body = new String(body2);
  5.     INDArray arr = Nd4jBase64.fromBase64(body);
  6.     exchange.getIn().setBody(arr);
  7.   }
  8. }).to("direct:receive");

代码示例来源：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-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-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: org.apache.camel/camel-hazelcast

  1. private void add(Exchange exchange) {
  2.     final Object body = exchange.getIn().getBody();
  3.     exchange.getOut().setBody(ringbuffer.add(body));
  4.   }
  5. }

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

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

  1. @Override
  2.   void execute(Cache<Object, Object> cache, Exchange exchange) {
  3.     exchange.getIn().setBody(
  4.       cache.get(exchange.getIn().getHeader(JCacheConstants.KEY))
  5.     );
  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.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: OpenNMS/opennms

  1. @Test(timeout=60000)
  2. public void checkDefinedTimeout() throws Exception {
  3.   System.getProperties().setProperty(CamelRpcClientPreProcessor.CAMEL_JMS_REQUEST_TIMEOUT_PROPERTY, "12345");
  4.   CamelContext context = getContext();
  5.   CamelRpcRequest<EchoRequest,EchoResponse> wrapper = new CamelRpcRequest<>(new EchoRpcModule(), new EchoRequest());
  6.   CamelRpcClientPreProcessor camelRpcClientPreProcessor = new CamelRpcClientPreProcessor();
  7.   DefaultExchange defaultExchange = new DefaultExchange(context);
  8.   defaultExchange.getIn().setBody(wrapper);
  9.   camelRpcClientPreProcessor.process(defaultExchange);
  10.   context.stop();
  11.   assertEquals(12345L, defaultExchange.getIn().getHeader(CamelRpcConstants.CAMEL_JMS_REQUEST_TIMEOUT_HEADER));
  12. }

代码示例来源：origin: eu.limetri.platform/platform-server

  1. @Override
  2. public void process(Exchange exchange) throws Exception {
  3.   Object object = exchange.getIn().getBody();
  4.   String xml = marshall(object);
  5.   exchange.getOut().setBody(xml);
  6.   exchange.getOut().setHeader("Content-Type", MediaType.APPLICATION_XML);
  7. }

代码示例来源：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.switchyard.quickstarts/switchyard-soap-mtom

  1. @Override
  2. public void process(Exchange exchange) throws Exception {
  3.   String newFileName = "internal-resized-switchyard.jpeg";
  4.   Image input = exchange.getIn().getBody(Image.class);
  5.   exchange.getOut().addAttachment(newFileName, new DataHandler(input, "image/jpeg"));
  6.   exchange.getOut().setBody(newFileName);
  7. }

代码示例来源：origin: redhat-developer-demos/istio-tutorial

  1. private void handleHttpFailure(Exchange exchange) {
  2.     HttpOperationFailedException e = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, HttpOperationFailedException.class);
  3.     exchange.getOut().setHeaders(exchange.getIn().getHeaders());
  4.     exchange.getOut().setBody(String.format(RESPONSE_STRING_FORMAT,
  5.         String.format("%d %s", e.getStatusCode(), e.getResponseBody())
  6.     ));
  7.   }
  8. }

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

  1. @Override
  2.   void execute(Cache<Object, Object> cache, Exchange exchange) {
  3.     exchange.getIn().setBody(
  4.       cache.getAll(
  5.         exchange.getIn().getHeader(JCacheConstants.KEYS, Set.class))
  6.     );
  7.   }
  8. },

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

  1. public void process(Exchange exchange) {
  2.     Message in = exchange.getIn();
  3.     in.setBody(body);
  4.   }
  5. });

代码示例来源：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-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: eu.limetri.platform/platform-server

  1. @Override
  2. public void process(Exchange exchange) throws Exception {
  3.   Object object = exchange.getIn().getBody();
  4.   String json = marshall(object);
  5.   exchange.getOut().setHeader("Content-Type", MediaType.APPLICATION_JSON);
  6.   exchange.getOut().setBody(json);
  7. }

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

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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