问题标签 [poller]

如何使用 java dsl Integrationflows 从 spring 集成中触发 spring 批处理作业。

我有下面的代码轮询目录中的文件，当一个新文件添加到目录中时，会生成一条消息，我想在那个实例上触发一个 spring 批处理作业。请指教。

我经历过 osb 12c db poller 工作正常，但突然间它停止从 db 轮询记录。检查日志时，发现 4 个受管节点内存中有 2 个已填满。但其他两个工作正常。

不知道为什么它突然停止轮询记录。有人可以在这里提供帮助吗？以下是 JCA 属性。

我们在我们的应用程序中使用 spring poller 来轮询来自 mySQL DB 的数据并发送给第三方。该功能可以正常工作，但是当我们转移到 PRODUCTION 时，因为我们有多个 appservers ，该作业正在所有服务器上运行，我们需要在所有服务器上运行它来处理传入的请求。

轮询时间配置为每 5 秒运行一次。

但是，即使我们添加了更新语句，一条特定的记录也会在多个服务器中被拾取，因为它们同时运行。

我们有以下配置

PollerService 类将为来自上述轮询器的每条记录调用如下

公共类轮询服务 {

您能否确认是否有任何交易设置可以限制我们在其他服务器中选择相同记录。

我是 Apache Camel 框架的新手。我必须在 Spring Boot 和 Camel 中开发一个应用程序，它反复轮询给定的目录（即使在目录经过任何修改之后，轮询器也应该继续轮询另一个预定的时间间隔等等。我在骆驼中发现了类似下面的代码。

公共类 FilePoller 扩展 RouteBuilder {

}

上面的代码只等待1秒，然后不轮询目录就执行后面的代码。

任何人都可以帮助我开发一个 Spring Boot-Camel 应用程序，该应用程序在每个给定的时间间隔重复轮询目录或文件。提前致谢

我正在使用用于 java 的 fabric8 库在 Kubernetes 集群上部署应用程序。

我想轮询 pod 的状态以了解它们何时准备就绪。我开始自己写，直到我读到了 Watcher。

我实现了这样的东西

我不确定我是否正确理解了 Watcher 的功能。是否超时？还是我仍然在 eventReceivedMethod() 中编写轮询器？观察者的用例是什么？

我正在开发一个SMPP必须能够每秒发送特定数量的短信的平台。

amqp使用spring 集成很容易实现这一点。

但：

我需要在 2 个节点上将项目作为active-active服务运行，并且每个节点都连接到 2 个 SMSC。对于此配置，我的允许流量为 100 msg/s，并且我需要将我的流量理想地分布在所有可用连接上。

一个简单的轮询器可以很容易地为每个节点配置为 25 msg/s (4 * 25 = 100)，但是如果我的一个连接断开，我想将丢失的容量分散到实时的其他节点/连接。

为此，我想创建一个动态轮询器，它获取有关 redis 中连接状态的信息，并仅调整运行时每次轮询允许的消息量（例如，断开连接为 0，其他 3 个连接为 33%，如果连接为 50%，则为 50% 4 上只有 2 个连接可用）。

是否可以使用自定义 PollerMetadata 来实现此行为，还是应该寻找其他解决方案？

I have an FTP message source and I want to enable the user to configure the poll frequency through an application.

This is the current configuration of the Inbound channel adapter

My goal is to retrieve the cron expression from the database. Is There a way to achieve this?

Thank you

Pollers.fixedDelay(5000)spring integration和Pollers.fixedRate(5000) in spring integration和有什么区别Pollers？

我正在尝试从可能出现一个或多个文件的系统文件夹中轮询文件，对于这些文件，我必须只触发一次批处理作业，而不是次数等于文件夹中的文件数。在我的情况下，我的批处理一次处理多个文件，我只希望轮询器将信号发送到批处理一次以开始其工作。

尝试了 poller.maxMessagesPerPoll(1) 等，但它有所不同。我面临的问题是，批处理作业被触发等于轮询文件夹中的文件数。我只想执行一次批处理

当前行为 -当轮询器检测到给定位置的文件/文件时，配置的批处理作业会触发多次。如果文件为 4，则批处理作业触发 4 次。

预期行为 -在文件轮询之后，批处理作业应该只对任意数量的文件执行一次。因为批处理作业一次处理多个文件，因此不需要多次执行。

让我知道您是否需要我提供的任何其他信息。请优先提供帮助

我正在构建一个企业应用程序，并且我正在使用活动 mq 进行应用程序之间的内部通信。当我将任务执行器与轮询器 AbstractPollingEndpoint 和 ErrorHandlingTaskExecutor 对象实例一起使用时，会导致内存泄漏。即使应用程序处于空闲模式，堆中的对象计数也会增加。当我关闭这部分代码 .taskExecutor(outTaskExecutor) 时，问题不再发生。但是我们正在为繁忙的流量做准备，我们不需要提供更多的线程来处理消息。我究竟做错了什么？你能帮忙吗？谢谢

可视 VM 堆比较