Apama JMS 相关器适配器动态流控制

Apama JMS Correlator Adapter dynamic flow control

在 Apama 中有没有办法动态地 stop/start JMSConsumer 作为 JMS 适配器的一部分?

是的,实际上有两种方法可以实现此目的:

a) 您可以通过 removing/re-adding 和 receiver/consumer 来完成,我们的 EPL API 支持它。对于与您提到的 stop/start 概念具有相同语义的队列,而对于主题,您会错过在停止和重新启动之间发送的消息。

b) 使用接收器流量控制功能 http://www.apamacommunity.com/documents/10.3.0.1/apama_10.3.0.1_webhelp/apama-webhelp/index.html#page/apama-webhelp%2Fco-DepAndManApaApp_receiver_flow_control.html 如果流量控制是目标,这可能会给你一个更有效的方法来解决它,即如果出于某种原因(太多操作)减少或暂停接收正在进行中,某些下游组件或数据库出现故障需要取得进展)您目前还没有准备好处理更多传入消息。正如该文档主题中提到的,有一个示例展示了如何在 EPL 中执行此操作,因此应该非常容易上手。