在Apama中,有没有办法动态地停止/启动JMSConsumer作为JMS适配器的一部分?
发布于 2019-02-28 20:12:24
是的,实际上有两种方法可以实现这一点:
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,如果流量控制是目标,它可能会为您提供一种更有效的方法来解决此问题,例如,如果由于某些原因(正在进行的操作太多,某些下游组件或数据库失败),您当前不准备处理更多传入消息,则可以减少或暂停接收。正如在doc中提到的,有一个示例展示了如何在EPL中使用它,因此它应该非常容易上手。
https://stackoverflow.com/questions/54923811
复制相似问题