Apache骆驼：Pollenrich不称呼动态URI
我有一条轮询服务器电子邮件的路线。在 fornctROute 中，我正在尝试通过 emailpollingRoute 中的Pollenrich方法通过IMAP协议来传递电子邮件的主题。目…
如何使用CameltestSupport模拟对某些预期对象的响应？
在构建器方法上创建了一个DTO（假设它只有一个随机值的“名称”属性），我想检查返回的对象是否具有相同的值，但响应为null。 单元测试代码： class G…
org.apache.camel.nosuchbeanexception for错误处理程序映射到路由
我有以下路由定义文件（linehaul-routes.xml）：
来自ActiveMQ的重新输入消息
当消息消耗消息并且处理消息存在问题时，该消息没有保存在数据源中。由于该消息是消耗的，因此不存在ActiveMQ经纪人和DataSource中。 有没有办法从Act…
如何依次调用多个路线而不弄乱身体
我有以下内容： .from("direct:start") .to("direct:a") .to("direct:b") .to("direct:c"); 我遇到的问题是直接：a 修改身体，然后将修改后的身体传递…
Apache Camel Kafka在生产MSG之前总计但丢失标头
我使用apache骆驼kafka与春季靴子 ＆lt; camel.version＆gt; 3.14.2＆lt;/camel.version＆gt; 我在apache骆驼kafka组件上使用了默认配置， org.apache…
骆驼和卡夫卡是否可以使用请求 - iip（inot）？
是否可以使用Camel和Kafka实现请求 - 重新企业集成模式（EIP）？ 它可以与ActiveMQ配合使用，但我无法与Kafka一起使用。在消费者收到请求之前，Produc…
com.fasterxml.jackson.databind.exc.mismatchedinputexception：无法对类型的值进行`com.com.company.fruitslist＆＃x27;从阵列值（令牌＆＃x27; jsontok
我刚刚开始在Java进行编码，所以这个问题听起来很愚蠢。 目标： 我正在尝试构建一个使用Apache Camel路由的Quarkus Rest应用程序，该应用程序具有邮政…
途中的单一感受导致无限循环
我有此 Onexception 在我的路由前块之前， onException(Exception.class) .process(new IncProcessor(IncService)) .handled(true); 处理器要做的是抓…
Apache骆驼SFTP获取文件内容null
java代码 @Component @RequiredArgsConstructor public class WireInboundFileListener extends RouteBuilder { private final JwtWireTokenService j…
一次运行一条Apache骆驼路线
我的产品具有使用Java编写的摄入服务，该服务运行Apache Camel路线。在不同的VM上运行多个摄入服务实例。摄入服务使用SQL Server 2016数据库服务器。…
有什么方法可以在Apache Camel中自动重新启动Debezium连接器？
我正在使用 debezium sql sql sql sql serve camel camel for apache camel 从一个数据库更改为另一个数据库。 @Configuration class DebeziumRoute e…
我应该在Apache骆驼路线上付出多少努力，而不是在处理器中写逻辑？
我使用骆驼进行一些消息处理，从源中获取消息，对其进行按摩，然后将其发送到某些目标。 但是我试图将其用于更复杂的用例，不确定我的方法是否正确。…
