jjzjj

DefaultMessageListenerContainer

全部标签

java - DefaultMessageListenerContainer 不缩放

我有一个DefaultMessageListenerContainer,它(在我看来)没有按比例放大。Container被定义为监听一个队列,其中有100条消息。我希望容器可以达到任何长度,消息将尽可能快地被消耗(通过观察maxConcurrentConsumers配置)。所以我假设有7个并发消费者。(从容器启动时的2个并发消费者开始)一些日志信息:activeConsumerCount:5concurrentConsumers:2scheduledConsumerCount:5idleConsumerLimit:1idleTaskExecLimit:1maxConcurrentCon

java - 我如何控制 Spring 从队列接收的速率?

我正在使用Spring的消息驱动POJO框架(尤其是DefaultMessageListenerContainer)来监听多个队列和主题。在一个特定队列的情况下,需要减慢我排空队列的速度,大约每五分钟一条消息。消息的实际处理是亚秒级操作,但我希望监听器在消息之间闲置一段时间。我创建了一些hack,但绝对不是最优的:我所做的是将最大并发设置为1并添加一个Thread.sleep(..)处理每条消息后。我想找到一种方法,而不是使用DefaultMessageListenerContainer在尝试接收之间等待,而不是让处理程序在可能处理消息的过程中进行等待。我考虑过是否有一个Schedul

java - 如何限制 JMS DefaultMessageListenerContainer 重试消息的次数?

我正在使用SpringJMS连接到WebsphereMQ服务器。我实现了SessionAwareListener接口(interface)来创建自定义监听器,为业务逻辑重用旧代码。在测试时,监听器抛出StringIndexOutOfBoundsException,但我未能捕捉到。但是,我在日志中看到以下内容打印了大约32次,然后DMLC停止了。WARN-ExecutionofJMSmessagelistenerfailed有没有办法控制DMLC重试消息的频率,以及如何处理未捕获的异常? 最佳答案 您始终可以检查JMSDelivery