apache-camel 相关问题

骆驼重置时执行最后一个状态

如果我们定义一条路由，包含调用多个服务，比如订餐服务，包含调用厨房服务、计费服务、送餐服务。 现在，如果厨房

数据集成软件和ESB有什么区别？

我一直在从事一个项目，该项目从各种第三方数据源收集数据并挖掘到我们的数据存储（DI）中。为此我们一直使用 Pentaho。 我想知道这是否也可以...

Camel-Kafka 安全协议 SASL_SASL 不起作用

以 Camel-Quarkus 提供的官方示例为起点，我修改了逻辑，以便写入 Kafka 代理。 Camel Kafka 组件全部指向本地代理

Spring Camel 集成测试因超时消息而变慢

从RabbitMQ切换到Spring RabbitMQ后，maven故障安全测试变得更慢，有多个消息 o.a.c.i.engine.DefaultShutdownStrategy ：优雅期间发生超时

Spring Boot 3 迁移时，出现 org.apache.camel.CamelExchangeException: Exchange is not part of a saga

在将我的应用程序的 Spring Boot 版本升级到 3.0.7 并将 Camel 升级到 4.0.1 时，我开始收到 CamelExchangeException 消息，说 Exchange 不是我的一个测试的传奇的一部分。 org.apache.camel.

使用 Spring Boot Camel 和 DelayedDelievery 会导致 Consumer 阻塞，直到重试耗尽

我们正在使用 Apache Camel 和 Spring Boot 来实现一个解决方案。我们的要求是将系统配置为在将失败事件路由到 D 之前重试指定次数的迭代...

Camel oneException重试失败路线

我是camel新手，在异常情况下我正在调用failureRoute，并且在failureRoute中我正在向MQ写入失败消息。但是，如果失败路线中出现任何异常（例如连接到 MQ），我想...

Apache Camel：邮件消息未设置任何收件人

camel-context.xml camel-context.xml <route id="mail-route-imap" autoStartup="true"> <!-- Trigger the route using a timer --> <from uri="timer://loadEmailParams?period=10000" /> <!-- Process the bean to fetch IMAP URL and Port --> <process ref="emailConfigProcessor" /> <!-- Log the dynamic properties --> <log message="Fetching from IMAP URL: ${exchangeProperty.imapUrl}, Port: ${exchangeProperty.imapPort}" /> <!-- Fetch emails dynamically using toD for IMAP --> <toD uri="imaps://${exchangeProperty.imapUrl}:${exchangeProperty.imapPort}?authenticator=#exchangeAuthenticator&amp;mail.imaps.auth.mechanisms=XOAUTH2&amp;searchTerm=#customSearchTerm" /> <!-- Log the successful fetching of emails --> <log message="Fetched emails from ${exchangeProperty.imapUrl}" /> </route> 处理器： @Component public class EmailConfigProcessor implements Processor { @Autowired private EmailConfigBean emailConfigBean; @Override public void process(Exchange exchange) throws Exception { exchange.setProperty("imapUrl", emailConfigBean.getImapUrl()); exchange.setProperty("imapPort", emailConfigBean.getImapPort()); } } EmailConfigBean @Component("emailConfigBean") public class EmailConfigBean { public String getImapUrl() { return "myoutlook.com"; // Example IMAP URL } public String getImapPort() { return "993"; // Example IMAP Port } } 错误： java.lang.IllegalArgumentException: The mail message does not have any recipients set. at org.apache.camel.component.mail.MailBinding.populateMailMessage(MailBinding.java:157) 当您想要使用邮箱时，不能使用<from uri="timer..."。由于邮件组件同时支持 consumer (from) 和 producer (to)，因此它的行为完全不同。 consumer 将从邮箱中读取电子邮件，而 producer 将发送电子邮件。因此，当在 to 端点中使用时，它会抱怨缺少收件人。 有几种机制可以安排消费者（实际上摆脱“触发”计时器）。然而，这不会帮助您处理动态 url，因为您需要首先触发处理器。 现在如何继续取决于您的实际设置。例如，如果您有固定的主机和端口列表，则可以设置 Map 或 List，用连接数据填充它们，然后通过 for 循环创建多个路由。由于我从未使用过 xml DSL，只使用过 Java DSL，所以我不确定这是否可以通过 xml 实现。 这是 java dsl 的示例： @Component public class MyRoute extends RouteBuilder { List<String> connections = List.of("myoutlook.com:993"); @Override public void configure() throws Exception { for (String connection: connections) { from("imaps://" + connection + "?authenticator=#exchangeAuthenticator&amp;mail.imaps.auth.mechanisms=XOAUTH2&amp;searchTerm=#customSearchTerm&delay=10000") .routeId("mail-route-imap") .log("Fetched emails from " + connection); } } }

com.azure.messaging.servicebus.ServiceBusException：类型的映射条目值没有已知编码：io.cloudevents.SpecVersion

我们使用 Azure 服务总线作为消息传递应用程序。使用 Apache Camel 将数据发送到 Azure 服务总线。它在 3.21.2 版本中工作。我们已将版本升级至4.4.3。升级后...

以 Apache Camel Exchange 作为参数的单元测试功能

我正在做javacamel开发，我想对一堆函数进行单元测试（junit4），并将Exchange作为参数传入。 例如 ： public FinalObject getProperty(最终交换exch...

有关将 Quartz 与自定义 Camel 消费者一起使用的问题

我正在开发一个自定义组件、端点和消费者。 它通常与默认的Camel调度选项一起使用：initialDelay和delay。 公共类 MyEndPoint 扩展 ScheduledPollEndpoi...

无法使用 Qpid JMS 向 ActiveMQ Artemis 发送大消息

我尝试从磁盘读取一个大文件并将其发送到 ActiveMQ Artemis 上的队列。每次我尝试都会遇到相同的异常： 导致：jakarta.jms.MessageFormatException：仅对象化原语

使用Apache文件组件分块读取大文件进行处理，而无需将整个文件内容加载到内存中

当路由语句“from(file://dir/largefile.txt)”拾取文件时，apache 文件组件将整个文件加载到内存中。问题是文件大小为 300MB，其中

Camel json 验证器支持 json 草案 07

我们使用 Apache Camel Java DSL 和 json-validator 组件来根据 json 模式验证 json 请求。当前的camel版本是2.22.0，根据camel文档是这样的

在 Camel YAML DSL 中引用一个 bean 到另一个 bean

我正在使用 Camel YAML DSL 连接到 IBM MQ 队列以接收消息。我在为 JMS 组件中使用的 IBM MQ 创建连接工厂时遇到问题。标准的javac...

如何集成各种应用程序并提供通用接口来访问其数据？

我们有一些不同的应用程序来存储其数据，我们需要一种通用服务来提供对这些数据的访问。 我指的是应用程序，例如 Atlassian Jira、Confluence、SVN...

在 Spring Boot Apache Camel REST API 中接收列表<MyDtoClass>时遇到问题

github 链接：https://github.com/shahulsley/came-rest-dsl 我已经使用 Apache Camel REST DSL 在 Spring Boot 中编写了 REST API。除了 createBatch 之外，所有端点都工作正常， 获取ID 获取所有文档 删除

大量带有选择器 JMSCorrelationID='CamelDummyJmsMessageSelector' 的异步消息使用者

我正在使用 apache Camel 使用 spring-jms 和 ibm-mq 配置 jms 请求/回复模式。 我的 Camel Route 配置为 InOut 模式，我能够成功地从回复队列中读取消息...

如何在CamelSpringBootTest中启动CamelContext之前模拟Apache Camel Route

也许是一个相当不常见的问题，但我想在 JUnit 设置方法中模拟某些 Camel 路由 @BeforeEach 无效设置（）{ } 之前 @覆盖 公共无效配置（）抛出异常{ } ...

如何在 Camel 中永远重试失败的消息？

我有一个场景，我的骆驼路由监听 KAFKA 通知消息，将它们转发到基于队列的日志服务，然后转发到 REST 端点。例如，如果失败，我...