问题标签 [poller]

每当 Spring Integration Poller 轮询事件触发时，是否有办法记录调试语句？我试图弄清楚我的轮询器出了什么问题，它似乎挂了更长的时间间隔。每当轮询事件触发时，我想开始简单地写入日志。这是我的 poller bean 定义：

这是线程转储的开始：

我有一个用例，我有 2 个 SQS 队列，每个队列都在获取消息。但条件是如果我在 FIRST 队列中获取消息，我将停止从 SECOND 队列读取消息并优先考虑 FIRST 队列消息。我可以只使用一个 SQS 轮询器来处理这个问题吗？

问题陈述：我经常在 FIRST 队列中收到消息，但这些消息很重要。但我不断地在 SECOND 队列中获取消息。所以，如果 poller 正在处理 SECOND 队列的消息，并且突然在 FIRST 队列中出现新消息，那么在处理完 SECOND 队列的消息后，它应该跳转到 FIRST 队列并开始取从那里开始的消息，直到第一个队列为空。

有解决办法吗？

我正在尝试在 Go 中创建一个轮询器，它会旋转并每 24 小时执行一次函数。

我还希望能够停止轮询，我试图通过拥有一个完成的通道并传递一个空结构来停止 for 循环来做到这一点。

在我的测试中，for 只是无限循环，我似乎无法停止它，我是否错误地使用了 done 通道？股票行情按预期工作。

这是执行代码并导致无限循环的测试。

在我们的项目中，我们需要从远程 ftp 服务器检索价格。在办公时间内，这工作正常，价格被检索并成功处理。办公时间之后，FTP 服务器上没有发布新的价格，所以正如预期的那样，我们没有发现任何新的价格。

我们的问题是，在几个小时没有找到新价格之后，轮询器停止了轮询。日志文件中没有错误（即使org.springframework.integration在调试级别上运行）也没有异常。我们现在使用单独TaskExecutor的来隔离问题，但轮询器仍然停止。与此同时，我们调整了 cron 表达式以匹配这些时间，以限制资源使用，但轮询器仍然在它应该运行时停止。

非常感谢解决此问题的任何帮助！

我们使用@InboudChannelAdapteron a FtpStreamingMessageSource，其配置如下：

属性值为：

我们限制每分钟使用检索的 poll.cron。

在相关DefaultFtpSessionFactory的 中，超时设置为 60 秒以覆盖默认值 -1（这意味着根本没有超时）：

我有一个 spring 集成轮询器，它轮询 NAS 中的目录。在本地运行应用程序时，轮询器可以完美地提取文件。但在 PCF 中，它仅在应用程序启动期间或应用程序重新启动时才获取文件。我已经为 Spring Integration 启用了调试日志记录，并验证了轮询器在 PCF 中以预定的时间间隔运行。但它不会拾取文件。NAS 共享通过 SMB 卷服务绑定到应用程序。感谢任何帮助。

我有多个供应商的应用程序。因此，我正在尝试为fixed-delaySpring Cloud Stream 中的特定供应商进行配置。例子：

应用程序.yaml

代码片段

但是根据spring的文档https://docs.spring.io/spring-cloud-stream/docs/3.1.2/reference/html/spring-cloud-stream.html#_polling_configuration_properties，好像只能配置一个org.springframework.cloud.stream.config.DefaultPollerProperties应用程序中的整个供应商的 bean。这个对吗？

我是 Spring 集成和消息传递通道的新手，请您帮助我处理 JDBC Spring 集成消息传递通道。

我创建了 3 个应用程序 Poller 、 Executor 和出站通道，但我很困惑这 3 个应用程序将如何通信和发送消息。

如何使用 .xml 从 xml 下方配置请求通道和回复通道IngrationFlow。

我的代码 -

如何在上面的代码中配置请求通道和回复通道，并将有效负载发送到回复通道。

在我的集成流程中，我在某些错误条件下从标准流程更改为错误流程，通过将standardStateEntryPoint启动errorStateEntryPoint/停止命令消息发送到Control Channel.

是这样的errorStateEntryPoint：

它具有Poller5_000 毫秒的固定延迟。开始时识别的生命周期是

从延迟开始，是否有可能有相反的生命周期？

任何人都可以在配置文件中与 cron 表达式一起使用 Spring Boot 应用程序中的工作示例吗？

我尝试使用下面的代码片段来安排外部应用程序。这在精确的 10 分钟间隔内工作 5 次，然后停止。

寻找建议

我们需要自动化测试场景，我们必须从基于 Poller 的服务中获取详细信息（这将在现有数据更新或创建新记录时获取数据），一旦选择记录，我们就会在内部处理它们。

我想知道我们如何自动化这个过程来挑选记录作为测试的一部分。