问题标签 [spring-integration]

我们正在构建一个仅与 JMS (ActiveMQ) 连接的分布式 Java 系统（应该是可扩展的；-)）。我研究了 Spring Integration，但我不确定如果我们使用它会有什么优势。我认为我们最好使用 Spring Core 项目中的 JMS-Templeate，因为我们只将消息从 JavaService 发送到另一个 JavaService 等等。

我有这个用例。

第一条链：

这是相关代码：

一切都很好。

然后我有另一个链：

和相对激活剂：

CensimentoCliente如下所述的List有效负载具有第一个链的有效负载，因此我使用拆分器拆分列表并重用第一个链的代码。

但是由于每个激活器都获得了他的事务定义（因为第一个激活器可以在没有第二个激活器的情况下存在）我有一个事务分离的用例。

目标是让两条链的数据库修改成为同一事务的一部分。

有什么帮助吗？

亲切的问候马西莫

我是 Spring 集成的新手。我有一个要求使用 spring 集成

1. 读取一个 txt 文件（来自 Source 文件夹）
2. 做一些验证
3. 如果验证成功 - 写入成功文件（在成功文件夹中）
4. 如果验证失败 - 写入失败文件（在错误文件夹中）
5. 如果文件格式不正确意味着我必须将该文件移动到错误文件夹中（例如例外列是 2，但在我的文件中包含列是 1）

我的配置文件是这样的

我的 checkFlatPackCVSParserWrapper 类是

sampleFileFormat.xml 是

我的 ErrorChannelWriter 是

我的验证课程是

我的 ListToStringTransfomer 是

我的文件包含一个字段而不是两个字段

这里我的文件格式错误，所以记录正在移动到错误文件夹。但没有错误消息。当我的文件格式不正确时，如何添加错误消息（想要的列太少：2 GOT：1）。我的要求在我的错误文件中应该包含

maya - 想要的列太少：2 GOT：1 或（任何错误消息）

请给我任何解决方案

有谁知道在哪里可以找到一些用于 Visio 的 Spring 样式集成图像 - 只是一个模板，或者可以在哪里下载 Spring Integration 设计器 GUI 中使用的图像，如下所示：http: //blog.springsource.com/wp -content/uploads/2010/10/si-sts-editor.png

对于其他感兴趣的人，仅供参考，这些 EIP 模板适用于 Visio http://eaipatterns.com/downloads.html。

但是我希望使用 Spring Integration GUI 中使用的那些来保持一致。

干杯!

我有一个固定线程java程序。它是用 Spring Integration 和 ActiveMQ 实现的。这里的固定线程意味着程序有多个线程，但它们在运行时的数量不会改变。现在我需要为其设置连接池大小，所以我应该知道：

1. 它有多少个线程
2. 它们中的哪一个可以同时连接到数据库。

1.我使用visualVM工具。

• 我可以将 visualVM 用于 2. 吗？如何？
• 有没有人解决这个问题？

我有一个带有 JMS 端点的 SprintIntegration 系统。消息的大小限制为 4mb。我的结果比那个大，我如何让 SI 把它分成几条消息？

/一个

如果我有一个带有邮件服务器入站通道的 Spring 应用程序，那么处理每封电子邮件中的每个文件的最佳方法是什么（我大约每 1 分钟轮询一次，并获取 1 封带有多个附件的电子邮件）。

虽然我可以在接收通道（SimpleAsyncTaskExecutor 或 ThreadPoolTask​​Executor）上应用多线程，但这并没有多大帮助，因为如果我在电子邮件中附加了 10 个文件，它们的处理几乎都绑定到一个线程。

到目前为止，我一直保持同步，因为我想为每封电子邮件汇总一些数据，并在处理完所有文件后发送响应。我相信这也可以以更好的方式完成。

一般来说，我如何异步处理每封电子邮件中的每个文件，然后再次异步构建电子邮件回复？

我有 java 对象，我想将其作为自定义标头传递给我在 http 出站网关上的请求。下面是一个片段

其中 UserContext 可能是一个 java 对象

我遇到的问题是标题 user_context 未映射到标题中。从日志中，我可以看到 DefaultHttpHeaderMapper 正在请求 Converter 或 ConversionService。见下文 -

请问我该怎么做？

谢谢！

我做了一些搜索，但找不到任何示例/示例。

我需要读取一个表（输入）中的地理坐标，并对其进行处理以生成与坐标相关联的 POI。因此，一个地理坐标将导致一个或多个 POI 需要插入到另一个表（输出）中。

我目前正在使用 JdbcCursorItemReader 和 JdbcBatchItemWriter 来读取一项/记录并写入一项/记录。还有一个 ItemProcessor 可以为给定的地理坐标生成 POI。

自定义 JdbcBatchItemWriter 是否可以帮助我实现这一目标？

有任何想法吗？TIA。

我正在使用 stomp 从 ruby​​ 脚本向 ActiveMQ 发送 XML 内容

我明确地将内容类型标头设置为application/xml;charset=utf-8，如下所示

但是，当我从使用 spring-integration 读取消息的 java 客户端读取消息时，内容类型是 text/plain。

结果，当调用 unmarshaller 时，解析失败并出现异常

可能是什么问题呢