我试着理解apache.camel交换的getIn()和getMessage()之间的区别。文档中说getIn()返回入站消息，而getMessage()返回当前消息。我的问题是:当入站消息在当前处理器中没有改变时，getIn()和getMessage()是否返回相同的消息？
浏览 29提问于2020-04-29得票数 3
回答已采纳
String json = gson.toJson(student); log.info("**********:{}", exchange.getMessage());我是Camel的新手，我试图在互联网上找到解决这个问题的方法，但没有得到任何帮助。 有人能帮帮忙吗？
浏览 11提问于2019-12-13得票数 0
试图从apache.camel下载文件。.routeId("downloadProcessId") String body = p.getInin.close(); e.getMessage} });
浏览 2提问于2022-08-15得票数 1
1回答
带消息号的骆驼头
、、
对于Apache，我想用不同的路由密钥发送到rabbitmq交换消息，以实现负载平衡(现在，我已经与4个路由密钥进行了交换，以后还会有更多)。是否有一种简单的方法可以向消息中添加不同的头(路由键.setHeader("rabbitmq.ROUTING_KEY"，envelope.getRoutingKey())？(Exchange exchange) throws Exception {
String id = exchange.ge
浏览 2提问于2018-12-18得票数 2
{ public void process(Exchange exchange) throws Exception { System.out.println(exchange.getIn().getBody()); })1234,56676,2345124,42
浏览 15提问于2021-02-17得票数 0
回答已采纳
当我将XML分成4个部分时，我希望将它们都放在另一个XML中，但它会覆盖，并且只有最后一部分 return newExchange; String oldBody = oldExchange.getIn().getBody(String.class);
String newBody = newExchange.getIn().ge
浏览 0提问于2016-10-01得票数 0
我得把我的项目和销售人员结合起来。更具体地说，我需要能够将一些salesforce.com数据批量导入到我们的系统中，例如帐户。我已经做了足够多的研发工作，得出结论认为SF散装API是可行的。public void process(Exchange exchange) throws Exception BatchInfo batchInfo = exchange.getInexchange.getException().printStackTrace();
浏览 7提问于2013-12-20得票数 3
回答已采纳
1回答
</route> public void process(Exchange exchange) throws Exception { }
只需调用ex
浏览 1提问于2014-07-13得票数 2
回答已采纳
我升级到camel 2.16，我的一条路径单元测试开始失败。下面是我的路由定义： public void configure() throwsExchange exchange = ExchangeBuilder.anExchange(new DefaultCamelContext()).build();值得注意的</
浏览 5提问于2016-06-28得票数 2
)在我的聚合策略中，我只设置了两个具有递增值的头：newExchange.getIn().setHeader("numberOfLines", numberOfLines);int sum = inMessage.getIn().
浏览 7提问于2022-08-18得票数 0
回答已采纳
我想聚合3个主题，但只是为了聚合策略的PoC，我尝试聚合2个主题。ProcessoInsere());
LOG.error("Error in the route: ", e);
String someData = (String) exchange.getIn(produ
浏览 44提问于2020-08-15得票数 1
回答已采纳
1回答
我试过了，我有一个类似于->的骆驼rest API.route() exchange.getIn().setHeader("CamelAwsDdbTableName
浏览 0提问于2020-07-25得票数 0
回答已采纳
我只是在尝试创建一个具有多个处理器的路由。是否可以检查某个特定的处理器是否正在设置任何交换。我正在尝试检查XML体中的message字段如果Message是hello，则设置exchange body并发送到queue3如果条件失败，则不应向queue3发送任何消息<Header() == "Hello") exchange.genIn().setBody("World"); exchange.getIn<
浏览 13提问于2020-02-21得票数 0
2回答
我从两个不同的文件位置读取和处理两个文件，并比较内容。如果第二个文件不可用，则进程的其余部分将使用第一个文件执行。如果第二个文件可用，则应进行比较处理。为此，我使用骆驼pollEnrich，但这里的问题是，骆驼是第一次选择第二个文件。如果不重新启动骆驼路线，第二个文件就不会被捡起来，即使它在那里。在处理完文件后，我会将文件移到不同的位置。from("sftp:" + firstFileLocation + "?
浏览 19提问于2022-08-08得票数 3
回答已采纳
myAggregationStrategy) .end(); String body = inMsg.getBody(String.class);
return ne
浏览 0提问于2015-01-22得票数 0
3回答
carReg)方法，我想将我从producer发送的参数传递到该方法中。当我使用不需要参数的执行方法进行测试时，路由是工作的，然后调用方法，路由返回请求的数据。此外，由于在调试模式下，我可以看到exchange保存了我传递的正确数据，因此Im发送的主体/参数被正确地传递到了路由交换中。问题是，当我想要在一个交换中调用我想要传递的参数的方法时，这个代码被标
浏览 37提问于2021-03-22得票数 0
(BeanDeserializerBase.java:1489) at com.fasterxml.jackson.databind.deser.BeanDeserializerBase未标记为可忽略的.com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException:未识别字段"SalesOrder“(com.orders.OrderModel类)，在没有被标记为可忽略的.25
虽然我指定的封送员使用的是salesOrder数据格式，但在最后
浏览 3提问于2018-02-27得票数 1
我使用"CamelHttpTransportServlet“公开rest服务，该服务接收订单并放置在jms队列中。代码在愉快路径上运行良好，并返回200响应。我编写了处理器来验证输入的JSON，并根据输入设置了http_response_code。void process(final Exchange exchange) throws Exception {
String requestBody = exchange.getIn().setBody("{ "error":
浏览 0提问于2018-02-27得票数 5
但是为了转换文件，使用的XMLReader从w3c网站下载xhtml dtd。
是否可以告诉xslt组件，将xml阅读器配置为使用本地版本(例如，通过使用xml目录)？
浏览 0提问于2013-02-19得票数 0
回答已采纳
云服务器
ICP备案
云点播
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号