4

Apama 中有没有办法动态停止/启动 JMSConsumer 作为 JMS 适配器的一部分?

4

1 回答 1

4

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

a) 您可以通过删除/重新添加接收器/消费者来实现,这由我们的 EPL API 支持。对于与您提到的停止/启动概念具有相同语义的队列,而对于主题,您会错过在停止和重新启动之间发送的消息。

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 中执行此操作,因此应该很容易上手。

于 2019-02-28T12:12:23.690 回答