问题标签 [spring-integration-dsl]

我正在尝试构建一个 IntegrationFlowFactory 来轻松构建集成流，以便在应用程序上下文之间传递事件。

一切似乎都正常，事件发布得非常快。

但是我无法弄清楚为什么消费如此缓慢。添加 concurrentConsumers 或更改 prefetchCount 似乎没有任何改变。

其他帖子谈到网络速度很慢，但正如您在 RabbitConfig 中看到的那样，我使用的是 localhost。

我在这里有一个带有我的 spring 集成示例的存储库： https ://github.com/teplyuska/spring-integration-example

我们有一个要求，我需要在两个不同的渠道中处理相同的消息（有效负载）。我们的印象是，使用 PubliSHSubscribe 频道将通过将消息复制到两个频道来帮助我们处理这个问题。然而，我们认为每个通道一个接一个地执行，如果 e 对一个通道中的有效负载进行任何更改，它也会影响另一个通道的有效负载。

在上面的示例中，如果我对 bean21 中的有效负载进行更改，它会影响传递给 bean 22 的输入有效负载。

我的要求是将相同的有效负载传递给 bean21 和 bean22 并并行执行它们？你能告诉我如何做到这一点吗？

我正在开发网络挂钩通知服务，允许客户端订阅/取消订阅流经中间件的消息，并通过将消息有效负载发布到提供的回调 URL 来获得有关消息的通知（根据提供的标准）。消息传递如下所示：

如您所见，uriFunctionsubscriptionsStore的实现通过订阅 id（消息头的一部分）获取回调 URL 。

我的问题是关于客户已经使用他的订阅 ID 取消订阅并且我在条件处理程序之后的情况。

filter我知道我可以过滤订阅 id 仍然存在于订阅商店中的消息，但这不是正确的解决方案，因为客户端可能会handle 在uriFunction.

另一种解决方案是使用回调 URL 到达标头，然后通过具有非空值的标头进行过滤，但我不想损害原始消息的标头和有效负载。

我可以考虑另一种方法：将不存在的订阅的 URI 计算为一些静态值，并添加拦截器RestTempalte来模拟此特定 URI 值的 HTTP OK 重播...

所以我的问题是关于使用标准 EIP 或其他我不知道的 Spring 集成功能来处理这种情况的正确方法......

谢谢

更新

我添加了DedicatedMessage包含上下文的类：

并将流程更改为：

这个方法有什么问题吗？

有谁知道如何为 FileInboundChannelAdapterSpec 设置 id？

这就是我构建入站适配器的方式：

提前致谢。

我正在尝试使用 Kafka 实现 Spring Integration Flow。但我被错误困住了。

当我调试时，我看到 "HandlerAdapter handlerMethod" is null is MessagingMessageListenerAdapter。不确定我在这里做什么，或者需要更多配置。但这是我可以从文档和其他页面中找到的全部内容。任何帮助表示赞赏

这是我的 pom.xml

和代码

我正在使用字符串集成 DSL 邮件从 POP3s 邮件服务器接收电子邮件。几个小时后，我看到轮询器停止轮询邮件服务器并且不处理电子邮件。我可以登录到邮件服务器并查看邮件在邮件服务器中。请您查看以下内容并让我知道这里有什么不正确的

我正在使用 SimpleWebServiceInboundGateway，目前我有网关将请求放到一个通道上，然后从通道中消耗一个流。一切似乎都很好。

我的问题是，如果您有多个不同的肥皂端点服务，每个服务的操作略有不同，我如何将这些端点映射到不同的流，这样做的正确方法是什么？是否期望每个soap Web 服务端点都有一个新的SimpleWebServiceInboundGateway 并使用EndpointMapper 映射到每个端点？或者有更好的做法吗？我不太确定它是否应该有多个 Soap 网关。

此外，有什么简单的方法可以访问用于在流程中进行 ws 调用的 URI/URL？我注意到它似乎不在标题中。

这是我的示例配置：

我目前是 Spring Integration 的新手。
基本上尝试使用 Java Spring 集成 DSL 异步轮询多个文件位置。我需要获取文件名并使用文件名执行一些操作并将文件最终推送到 S3，我的问题是这些对文件执行操作的任务可以在任务执行器或服务激活器处理程序中执行。我不确定哪个是正确的地方。

我在这里附上了示例代码。
还有一种方法可以检索通道中文件的文件名，因为我需要将其作为参数传递给 fileUpload 方法。请指教。

我无法让服务激活器处理程序连续运行，它们似乎没有一个接一个地运行。在下面的代码中，fileWriterMessageHandler 方法在 fileUpload 方法之前被调用。fileUpload 需要返回的标准返回值是多少？

已编辑 我是 Spring 集成的新手，我正在尝试将数据从服务激活器（通过句柄方法）传递到通道。

这是 FileProcessor 类

这是 Enricher 类： public class Enricher {

消息“丰富产品..”没有被打印出来，我不确定出了什么问题。