在运行时尝试使用Spring Integration修改轮询率时出现问题

Question

已将通道适配器定义为：

<int:channel id="target">
    <int:queue /> 
</int:channel>
<int-jdbc:inbound-channel-adapter id="adapter" channel="target" query="${int.poll.query}" update="${int.update.query}" data-source="mock-datasource">
    <int:poller fixed-rate="5000"/>
</int-jdbc:inbound-channel-adapter>

我想知道为什么我不能在运行时修改轮询率，如下所示：

SourcePollingChannelAdapter adapter = applicationContext.getBean("adapter",SourcePollingChannelAdapter.class);
adapter.setTrigger(new PeriodicTrigger(1000));

当我调试这个解决方案时，我可以看到适配器连接了这个新的触发器，但是轮询速率保持不变（每5秒）。我也尝试过停止（）和启动（）适配器，也有类似的运气。

有人能指出我做错了什么吗？感谢

Answer 1

[已解决]

Spring团队的成员已经确认，在运行时不能修改触发器。因此，如果您想动态修改轮询速率，例如限制入站消息，则必须滚动自己的Trigger实现，并为间隔轮询添加一个setter。

我在这里留下我的配置中所做的更改：

<int-jdbc:inbound-channel-adapter id="bancsAdapter" channel="target" query="${int.bancs.poll.query}" update="${int.bancs.update.query}" data-source="bancsMockDB">
    <int:poller trigger="dynamicTrigger" />
</int-jdbc:inbound-channel-adapter>
<bean id="dynamicTrigger" class="directlabs.integration.DynamicTrigger">
    <constructor-arg value="5000" />
</bean>

因此，对于节流，您只需要执行以下操作：

applicationContext.getBean("dynamicTrigger",DynamicTrigger.class).setPeriod(1000);

DynamicTrigger的实现可以在这里找到

Spring团队成员的原始评论可以在这里找到。

Answer 2

虽然这里的空间不允许使用完整的示例，但我们创建了一个使用Quartz Scheduler作为触发机制的服务。它接受一个定义了Quartz作业和触发器的XML文档（这个堆栈溢出描述了使用简单的XML驱动Quartz Sheduler的过程）

输入通道将接受用于在Quartz中设置时间表的XML。输入通道然后可以用于接受作业和触发器的动态更新。

作业映射数据中的xml条目将定义一个"输出"通道，并且可以添加其他作业映射数据，这些数据可以在输出消息头中设置以允许路由。

我们在许多Spring Integration上下文中不断重复使用此服务。

希望这能有所帮助。