骆驼窃听
我正在使用带有Apache骆驼的Spring Boot。我正在从控制器调用路由。一旦路由完成，控制就会返回控制器。我正在VerifyLimitProcess和批准限制处理器中生成响应。如果我没有在路由中提供窃听配置，控制器会按预期检索标头和正文。但如果我在路由中引入窃听，控制器会将标头和正文接收为null。如果有人指出我需要做什么，以便我可以在选择语句中引入两个处理器的窃听配置，即VerifyLimited和批准限制处理器，这将是一个很大的帮助。
提前感谢您的建议。
from(SERVICE_ENDPOINT).process(new ValidatorProcessor())
.to(bean:limitDataDaoImpl?method=getLimitData(${body}))
.process(new AuthorizationProcessor())
.choice()
.when(isLimitGreater())
.log("Limit is greater ")
.to(bean:limitDataDaoImpl?method=getVerifiedLimit(${body}))
.process(new VerifyLimitProcessor())
.otherwise()
.process(new ApprovedLimitProcessor())
.endChoice()
.end()
.wireTap("direct:auditEndPoint")
.executorServiceRef("wireTapThreadPool");
共有1个答案
endChoice（）。end（）可能是原因。只在结尾（）处尝试。换句话说，删除endchoice（）
-
我有一条小路线，我想使用自定义的重新传递策略来重复向endpoint发送消息，但这种行为非常奇怪。看起来，重新交付政策只是在重复一个错误。我试图将所有交换发送到路由的开头，但策略不起作用，因为每次都在创建： 我做错了什么？当错误发生时，我想以间隔重复我的请求。我的骆驼版本是2.6 日志：
-
我正在遵循位于Camel MyBatis Integration guide的安装指南。我使用的是Service Mix 5.0.1。我使用了安装spring mybatis的功能，它支持3.2.4。释放我的SqlMapConfig文件只包含有关TypeHandler和TypeAlias的信息。 当我开启服务混合，然后启动我的应用程序，我收到以下堆栈跟踪： ...还有50个 我的Bean定义如下：
-
我有一个Quarkus应用程序，它使用Apache-Camel并在本地运行良好。当我构建它并尝试运行docker容器时，我收到以下错误： 我的分级依赖关系是 } 当我在IntelliJ终端中使用“夸克斯开发”运行它时，我没有问题。我是否尝试运行容器，但会出现错误。为什么会发生这种情况？我不知道如何解决它。 编辑： 处理HttpException的位置: 处理程序本身： }
-
我试图弄清楚骆驼的节流概念。我已经看到了骆驼的航线政策，但这适用于许多飞行中的交换。 我的路线如下： 现在我的用例是，我想在这些路由之间传输比如说2000条消息，我知道可以通过来完成。但是，我不得不决定如何在下一个2000条消息被路由时控制它。我只想在接收者队列变为空时路由下2000条消息。 例如，消息从队列路由到。假设2K消息已成功路由，现在我想挂起我的路由，这样它就不会传输更多的消息，直到队列
-
我有一个apache骆驼路由，它正在交换主体上处理POJO。 请看从1到3标记的行序列。 现在，我需要对< code>hazelcast组件使用< code>put操作，不幸的是，该组件需要将body设置为值-1。 对于标记为 2 的行，我想将交换的副本发送到 路由。 首先，我尝试了，但交换体仍然被搞砸了（到-1）。 然后我尝试，它是一种“fire-and-forget”（异步）模式，但我实际上需
-
我创建了一个路由器类，并在@Configuration中标记为@Bean。有一件事我不太确定，那就是camel会多久调用一次数据库以获取select结果？一旦我在数据库中有了一个新条目，camel就会检索并处理它。