问题标签 [spring-dsl]

我试图从标头值设置 activemq 队列名称，但下面没有发生是我的 Spring DSL

日志 16:03:57,601 | 信息 | _route1 | x-so-queue-name::: IDC_SO_Refill_IO

标头值正在日志中打印，但队列名称设置为“$ {header.x-so-queue-name}”为什么它没有检索标头的值，我做错了什么

我正在使用 Spring 云流读取文件并使用文件拆分器拆分并使用 DSL 样式将每一行作为消息发出，正在读取的文件有一个标题行，只是想知道是否有一种简单的方法可以在 / 之前跳过标题行看完后。

任何帮助表示赞赏。

这是我的拆分器和集成流的样子：

我想让流程的特定部分成为事务性的。例如，我想在一个事务块中进行前两个转换操作。这是我使用的流程代码：

我找到了一种解决方法，即添加另一个句柄并将流引导到像这样的事务网关：

我还找到了中间流事务支持，但找不到可以处理的示例。

是否有一个优雅的解决方案，而不是直接指向流程中间的另一个网关？

我可以使用新的 Kotlin DSL 来设置路由吗，例如：

使用非反应性 Web 部件？从某种意义上说，底层数据库将是 Postgres 和基于非 Reactive servlet 的应用程序服务器，因此我不想/不需要使用 Flux 或 Mono 作为返回类型barHandler或存储库函数。但我确实喜欢与 Kotlin 一起使用的新路由器 DSL，它比基于注释的功能更强大，@RequestMapping并且更容易掌握所有应用程序路由。

我想通过 bean 遍历作为消息头传递给骆驼路由的 java 数组列表，以便每个基本上是 url 的字符串项都可以作为 uri 参数在骆驼路由的标签内传递。

我通过java bean将数组列表作为消息头传递给骆驼路由，如下所示

并且，在骆驼路线中，我想遍历这个列表并一个一个地检索每个列表项，以便我可以在 uri 中传递这些项目。这是我的骆驼路线：

但是我无法遍历在骆驼路线中作为 header.endpoints 接收的列表中的每个项目。

我正在尝试使用spring DSL搜索骆驼的tika示例。

我看到 tika 连接器可用，但没有使用 spring DSL 的示例。我查看了所有地方，包括https://github.com/apache/camel/tree/master/examples#examples链接，但到目前为止还没有运气。

任何机构都可以帮我解决这个问题。

我想根据 Spring Boot 应用程序的 application.yml 文件中的某些属性的值定义一些 bean。例如，number-of-beans: 5我构建了一个 for 循环来创建 5 个 bean 实例：

应用程序.yml

BeanDsl.kt

问题是此时如何访问环境，因为 env 变量在那里不可用。有趣的是它在bean{}元素内部。

主要应用：-

FilePollingIntegrationFlow 类：-

如何触发线程以一天中的固定时间（例如美国东部标准时间下午 5 点）检查系统时间，如果 sysyem 时间等于固定时间，则在使用 java dsl 和 spring boot 的 spring 集成项目中 System.exit(1)。

我想不通

1. 如何退出 Integrationflows 并转移到另一个程序或方法。
2. 运行一个单独的线程或在同一个线程之上运行轮询以实现我的功能。

请指教。

我有以下配置

我从一个兔子队列 orderPlaced 中读取，然后将对象解组为 OrderModel，然后执行两个过程，其中第二个过程将主体对象类型从 OrderModel 更改为 SalesOrder，但是在编组消息时出现错误

com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException：无法识别的字段“SalesOrder”（com.orders.OrderModel 类），在 [来源：java.io.ByteArrayInputStream@4eac8add；未标记为可忽略；行：1，列：16]（通过参考链：com.orders.OrderModel["SalesOrder"]）在 com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException.from(UnrecognizedPropertyException.java:62) 在 com.fasterxml。 jackson.databind.DeserializationContext.handleUnknownProperty(DeserializationContext.java:834) 在 com.fasterxml.jackson.databind.deser.std.StdDeserializer.handleUnknownProperty(StdDeserializer.java:1093) 在 com.fasterxml.jackson.databind.deser.BeanDeserializerBase。 com.fasterxml.jackson.databind.deser.BeanDeserializerBase 处的 handleUnknownProperty(BeanDeserializerBase.java:1489)。ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 在 java.lang.Thread.run(Thread.java:748) 被抑制：com.fasterxml。 jackson.databind.exc.UnrecognizedPropertyException：无法识别的字段“SalesOrder”（com.orders.OrderModel 类），在 [来源：java.io.ByteArrayInputStream@4a931757；未标记为可忽略；行：1，列：16]（通过引用链：com.orders.OrderModel["SalesOrder"]) ... 25 更多 （com.orders.OrderModel 类），在 [Source: java.io.ByteArrayInputStream@4a931757; 处未标记为可忽略；行：1，列：16]（通过引用链：com.orders.OrderModel["SalesOrder"]) ... 25 更多 （com.orders.OrderModel 类），在 [Source: java.io.ByteArrayInputStream@4a931757; 处未标记为可忽略；行：1，列：16]（通过引用链：com.orders.OrderModel["SalesOrder"]) ... 25 更多

虽然我指定 marshal 使用 salesOrder 数据格式，但最终由于某种原因它使用 orderModel 数据格式，但我无法确定原因。

这就是 SalesOrderConverter 最后所做的

我有一个applicationContext导入多个资源（骆驼上下文文件）的 xml 文件。

我在使用之前缓存了这个 xml 的定义new FileSystemXmlApplicationContext()。

说AddRequest.xml使用某种方法连接到某个主机，而 AdviseRequest.xml使用CXF端点连接到SOAP.

当我尝试加载时applicationContext xml，它会尝试在实际启动之前先缓存这两个文件camelContext。在这个阶段，它正在尝试检查CXF端点的可用性。无论如何处理这个，如果soap wsdl实际上是下来？

原因是，如果第二个 xml 中存在一些连接问题，我的第一个 xml 也会失败，因为它尝试一次缓存两者。

注意：我不能使用两个单独的applicationContext文件

我在骆驼路线中使用了以下代码。