apache-camel 相关问题

如何在 Apache Camel Spring Boot 中保持监督路由控制器运行

我尝试使用Camel文档中描述的监督路由控制器来重试启动路由（如果启动失败）。 我的 application.properties 文件中有以下几行： 骆驼.springboot...

Apache Camel+电子邮件：msal4j.AcquireTokenByClientCredentialSupplier 失败

我有一个 Apache Camel+Camel-email+Springboot 项目。我的camel-context 文件中的 IMAP 路由无法启动，并出现错误 org.apache.camel.FailedToStartRouteException: 无法启动路由邮件-...

如何正确调试路由

我在学习 Apache Camel 时遇到了一些问题。 我试图使用 jetty 和 Rest DSL 创建一个非常简单的休息服务，如下所示： 包 org.examples.routes.camelRestRoute; 导入 org.apache.

Apache Camel - 如何正确调试路由

我在学习 Apache Camel 时遇到了一些问题。 我试图使用 jetty 和 Rest DSL 创建一个非常简单的休息服务，如下所示： 包 org.examples.routes.camelRestRoute; 导入 org.apache.

Apache Camel Swift 转换器

我正在尝试使用 apache Camel 转换 swift MT-MX。我发现：APACHE CAMEL COMPONENT SWIFT MX 我尝试使用它： 公共类 MySpringBootRouter 扩展 RouteBuilder { @覆盖 p...

J2EE 应用程序服务器如何服务单个 WebService 调用

在一个项目的编码过程中，我遇到了一个疑问。 正如标题所示，我的疑问是 J2EE 应用程序服务器如何为单个 WebService 调用提供服务。 当客户端调用 WS 时...

从主题消费并根据消费消息中的主题名称发布到主题时会出现内存峰值

我有一个路由，它使用来自kafka主题的JSON字符串并将数据发送到另一个路由：direct:streamerRoute from("direct:streamerRoute").routeId("streamerRoute") ...

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

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

数据集成软件和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，其中