问题标签 [spring-integration-dsl]

我有一个异步 IntegrationFlow，它在不同的环境中有一些不同的行为。我将它部署在一个环境中，当我通过网关调用它时它会立即启动（这是所需的行为）。我将它部署在不同的环境中，并且当我在同一个项目中运行的单独的 cron IntegrationFlow 运行时，IntegrationFlow 将不会启动，直到每小时的顶部。我的问题是如何将这个 IntegrationFlow 配置为在被调用时立即启动或手动调用它，以便它始终立即运行。我真的很感激任何帮助。这是我的代码：

网关

集成流

呼叫服务

我有两个线程，线程中的每个方法都会引发异常。如何获取每个线程中引发的所有错误？在此代码中，错误通道仅捕获其中一个错误。基本上我的目标是捕获所有错误并将它们发送给调用者（休息控制器）。任何帮助将不胜感激。谢谢。

集成.java

MGateway.java

解决方案

以下配置接受带有要创建的用户实例的 JSON 请求正文的 HTTP POST，但如果我能让它返回一个201 Created. 有任何想法吗？

我尝试调用statusCodeFunction，HttpRequestHandlerEndpointSpec但我一定做错了。

我正在开发一项使用 spring 集成 java dsl 发送电子邮件的服务。

我有一条批处理消息，它被分成一组单独的消息，这些消息将变成电子邮件。

我遇到的问题是，如果这些单独的消息之一引发错误，则不会处理批处理中的其他消息。

有没有办法配置流程，以便在消息引发异常时，优雅地处理异常并处理批处理中的下一条消息？

以下代码实现了我想要的功能，但我想知道是否有更简单/更好的方法来实现这一点，理想情况下是在单个 IntegrationFlow 中？：

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

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

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

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

有没有人用 DSL 完成 spring-integration-jdbc StoredProcOutboundGateway 配置？

我想知道在 spring 集成中是否可以在流中包含一个外部通道。所以我有http入站网关流，在它被触发后，它应该通过udp端口​​与其他进程通信。我最关心的是如何从这个流中的 udp 端口​​接收消息。

使用 udpInboundFlow 应该作为某种轮询器来实现，它检查是否有正确的消息到达。

谢谢你的帮助。

我正在尝试设置一个集成流来使用来自亚马逊 sqs 队列的消息，并且到目前为止它工作正常。但我想调整每分钟或每秒的消息数量。例如每分钟 20 条消息。

这是我的 sql listener bean 的定义

如您所见，我设置了每次轮询要获取的最大消息数，但是如何设置轮询之间的延迟？

在常规 jms 队列中，我可以使用 JMS.inboundAdapter 使用自定义轮询器，但似乎使用 SqsMessageDrivenChannelAdapter 我无法设置任何轮询计时器值。

也许我可以使用除 SqsMessageDrivenChannelAdapter 之外的 MessageProducer，但哪一个？

是否可以使用 sqs 设置 JMS.inboundAdapter？

使用 Transformers.toJson() 我的 json 日期如下所示：

"createdDate":{"year":2017,"month":"OCTOBER","monthValue":10,"dayOfMonth":25,"hour":7,"minute":57,"second":36," nano":972000000,"dayOfWeek":"WEDNESDAY","dayOfYear":298,"chronology":{"calendarType":"iso8601","id":"ISO"}}

这是出站 ampq 配置：

兔子队列的消费者期望格式为“yyyy-MM-dd'T'HH:mm:ss.SSSZ”

有什么办法可以覆盖spring集成使用的默认ObjectMapper？

例如，我在扩展 WebMvcConfigurerAdapter 的 Web api 配置中有此配置：

有没有办法在 Spring Integration 中重用 objectMapper bean，以便映射配置在我的所有出站端点、web api http 或集成 ampq 中都是相同的？

我需要调整返回给集成流调用者的所有错误消息，这样我就不会泄漏信息，无论它们是作为异常抛出还是作为异步错误处理。我想避免在每个消息处理程序上定义自定义错误通道。我试图将变压器附加到默认错误通道但没有成功：

是否有一个中心点可以转换所有传出的错误消息？