Apache Camel是一个功能强大的开源集成框架,基于已知的企业集成模式和强大的Bean集成
Apache Camel - 使用 #Class 或 #Bean 配置端点
我是Camel新手,尝试使用#class(或#bean)配置sql端点的rowmapper属性。两者似乎都不起作用,因为它总是被视为字符串 公共字符串 getDBRouteURI...
在Springboot application.yml中添加Apache Camel相关配置属性
我遇到以下问题: 我有一个 Springboot 应用程序启动 Apache Camel 路由,将数据源连接到数据库。这运作良好,但一个数据源太慢(发布 val...
Camel幂等消费者检测到重复消息时如何返回不同的http响应码?
我想使用camel幂等消费者来确保消息只被消费一次。如果消息重复,我想返回状态 409,否则返回 204。 我的问题是,虽然代码有效
有没有一种聪明的方法可以使用camel和smooks编写固定长度的平面文件
有没有任何框架/库可以帮助用java编写固定长度的平面文件? 我想将 bean/实体的集合写入平面文件,而不用担心转换、填充、对齐,
当路由中发生异常并且未被异常管理器捕获时,会显示路由的详细信息,这有助于了解可能出了什么问题。 当异常被捕获并且
有没有更好的方法来只允许一个并发的骆驼路由执行并在路由运行时丢弃额外的请求?
目标: 我想跑骆驼路线,需要很长时间才能完成。我想要 使用 put 请求启动此路由。 我只想允许 1 个并发 该路线的处决。 我想丢弃任何
Apache Camel - 当只有一个 org.apache.camel.Exchange 类型的参数时,返回类型必须为 void
我正在使用 apache Camel 4.3.0 和 spring boot 3.2.1 和 java 17。我有一个路由(rest dsl),它接受 xml 并调用 bean 处理器方法,然后进行数据库调用并返回.. .
Apache Camel 4.7:disableStreamCache=true 不再按预期在 http 端点上工作
我们从 Apache Camel 3.16.0 升级到 4.7.0(包括将 Java 11 升级到 21)。我们必须在没有缓存的情况下流式传输大型 HTTP 响应,但这在新版本中不再按预期工作。我们...
由于某种原因,Camel SMB 组件没有像其他文件相关的 Camel 组件那样实现文件框架。因此,重要的部件配置属性(例如移动、包含、排除、
我需要使用 Camel 3 中存在但版本 4 中尚未存在的组件。 通过 JBang,我可以通过使其正确运行来驱动库版本: 骆驼运行 --camel-version=3.22.2
supervisingroutecontroller 并不监督所有路由
使用Camel 4.4.1和SpringBoot 3.2.3。 我有一个非常简单的骆驼路线构建器: 导入 org.apache.camel.builder.RouteBuilder; 公共类 SimpleTestRouteBuilder 扩展 RouteBuilder { 公开
如何避免与 Apache Camel 和 CXF 一起使用的 RedHat Fuse 适配器中的交换超时?
我正在使用 Apache Camel 和 CXF 在 Java DSL 中使用 RedHat Fuse 适配器。我正在尝试处理相对较大的传入 SOAP 消息,但遇到了超时问题。然后发件人
Apache Camel Postgresql Debezium 组件能否输出云事件
Debezium 连接器可以配置为输出云事件而不是默认的 Struct 对象。但是,当使用带有嵌入式 Debezium 引擎的 Apache Camel PostgreSQL Debezium 组件时...
如何在 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 时遇到了一些问题。 我试图使用 jetty 和 Rest DSL 创建一个非常简单的休息服务,如下所示: 包 org.examples.routes.camelRestRoute; 导入 org.apache.
我正在尝试使用 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") ...