问题标签 [spring-camel]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
708 浏览

apache-camel - Camel 2.18.0 pollEnrich 连接异常不会被 OnException 块捕获

我尝试在循环中使用 pollEnrich 下载具有动态文件名的文件,当 pollEnrich 出现连接异常时,即使在 pollenrich 声明之后,io 也无法在 onException 块中处理它,但我们无法进行 docatch。

我还尝试在端点 uri 中使用 throwExceptionOnConnectFailed=true。不是没用。

这有什么解决方法吗?

0 投票
1 回答
153 浏览

spring-boot - Spring Boot - Camel 如何处理多个进程

我有 3 个单独运行的 Spring Boot - Camel 应用程序。我需要链接这些进程,比如在进程 A 完成时它应该启动进程 B,然后一旦进程 B 完成,它应该继续进程 C。如果任何进程在两者之间失败,进程链应该重试失败的一个,然后继续执行到下一个。此外,在流程 A 中,如果路线中的任何步骤出现任何故障,那么我还需要重试并从中间步骤开始。任何人都可以帮助我实现这个场景吗?

0 投票
1 回答
832 浏览

spring - CamelContextStartedEvent 调用了两次

CamelContextStartedEvent为相同的骆驼上下文(camel-1)调用了两次。问题可能是我注册EventNotifier. 您可以使用 Spring Boot 1.5.14、Spring Boot Camel Starter 2.21.1 和 Spring Boot Web Starter 重现 Spring Initializr 的问题。

查看日志:

初始化的服务EventNotifier

EventNotifier: _

应用程序.yml:

0 投票
0 回答
40 浏览

java - 如何将 POJO 传递给绑定到 REST 路由的 mybatis

我正在使用声明一些 REST 路由,其中​​之一如下:

FaqLink只是一个带有 getter 和 setter 的 POJO idawardId等等。我随后也路由到 mybatis 查询,如下所示:

在 SqlMapper 中,即使我已经声明了ParamTypeas FaqLink(在声明为 a 之后TypeAlias),用作查询的一部分的变量,例如#{id}#{awardId}仍然解析为 null。

我做错了什么,我无法让 SqlMapper 从所述 POJO 中获取变量?我登录了${in.body},它似乎是一个实例FaqLink

0 投票
0 回答
1695 浏览

java - 如何在骆驼中将文件名从'from'传递到'to'?

我正在尝试弄清楚如何处理文件,然后将文件复制到 /finished 目录。如果我只是将“to”保留为目录,它会为我生成文件名。我想要相同的文件名。

在我的处理器中,我有:

在我的路线中,我有,例如:

关于使用“{file:name}”和“{in.header.CamelFileName}”有各种各样的建议,但没有一个对我有用。

(顺便说一句,xls.dir 末尾有 /,所以这不是问题)

0 投票
1 回答
298 浏览

java - 使用 application-test.properties 自动装配 Bean

我有以下 Test 类,并且我的 bean 总是根据我的src path中的 application.properties 自动装配。

简单属性已正确自动装配(queueFrom、queueTo...),但属性camelContext与主体application.properties文件自动装配

我想用测试路径中的特定属性文件自动装配我的 bean

这是我的测试类的标题:

谢谢你的帮助。

0 投票
1 回答
521 浏览

apache-camel - Camel 2.21.0 - 如何使用流处理异常

我想记录异常错误并继续下一个记录/拆分,但它不起作用。

我累了OnExcepiton()doTry()DSL 但它不起作用并转到 ErrorHandler。

日志:

0 投票
1 回答
784 浏览

spring - Spring中的Camel HeaderFilterStrategy Bean注册

我在使用 Spring-Camel 将 HeaderFilterStrategy 类注册为 Bean 时遇到困难,以便可以通过 Camel Route 找到它。我对 HeaderFilterStrategy 自定义类进行注释的尝试似乎是徒劳的……那么如何注册这个东西以便在运行时找到它呢?

我有一个使用自定义 HeaderFilterStrategy 的路线的骆驼应用程序

策略类看起来像:

我使用简单的注册表将其注册到骆驼:

我在我的路线中引用它

就像圣诞节晚上拉尔菲带着他值得信赖的红骑士 BB 枪一样,世界上一切都很好。

所以,现在我想把这个纯骆驼应用程序放在 Spring 下。我确保导入了所有适当的 Camel,以及 Spring-Camel 和 Spring 的东西。但是,当我尝试将 HeaderStrategy 注释为 Spring 的 Bean 时,它失败了:

现在,当我这样做时,IDE 基本上告诉我它无法自动装配方法调用中的任何参数,因为存在多个 String 或 Object 类型的 bean,并且没有找到 Exchange 类型的 bean。

在运行时,Camel 确实尝试解释路由,但由于“没有可用的“java.lang.String”的限定 bean 类型而引发失败,因为这是方法调用中的第一个参数......

那么,如何让这个东西能够正确注册注释呢?或者手动注册这个bean而不尝试自动装配?我所需要的只是将类注册为 BEAN,以便骆驼可以在运行时找到它......或者至少这是我理解需要发生的......那么我该怎么做呢?

0 投票
1 回答
43 浏览

spring-boot - 测试 Apache Camel + SpringBoot 时使用备用端点

我有一个简单的 Apache CamelRouteBuilder类,大致如下所示:

不过,在我要编写的测试中,我只想使用测试direct:split端点——我将加载 CSV 并在本地保存新的 CSV,然后编写测试以将输出与我期望的结果进行比较要的输出。RouteBuilder我会在我的测试中重写吗?或者我会以某种方式拉入direct:split端点,然后只指定不同的开始和结束位置?

0 投票
0 回答
38 浏览

spring - Spring 和 Camel 在单元测试中排除路由

我正在为 spring boot 项目中的骆驼编写测试,我想排除除我要测试的路线之外的所有路线。

所以在下面我想测试“ftp-poller”,我已经将路由拆分为单独的文件,但它仍然加载所有路由,我不明白是否可以只加载一个路由或者是因为它们链接它不是可能的