暂停 MessageListenerContainer 以在指定的时间间隔内使用新消息

Question

有没有办法暂停 MessageListenerContainer 以在指定的时间间隔内使用新消息？ 在我们的应用程序接收器中，我们将传入事件存储在 apache Spark 存储/缓存和执行程序进程事件中。在重负载期间（例如 50K 消息），如果处理延迟（即所有执行程序都忙），我们希望暂停使用新消息。作为解决方法，我们必须停止/启动 MessageListenerContainer，但它给人的错误印象是 Listener 由于系统故障/异常或由于处理延迟而导致程序化而断开连接。

Answer 1

框架中没有这个功能，只有stop()和start()。

当条件出现时，您可以简单地阻塞侦听器线程（例如使用CountDownLatch）。