java - 如何防止消息转到 "Dispatched Queue"

Question

我将 ActiveMQ 与 Spring 框架结合使用。

我在 JMS 容器中设置了两个使用者。当我向队列发送4条消息时，部分消息被转移到“Dispatched Queue”，因为消费者处理消息需要很长时间。

我正在尝试找到阻止消息进入“调度队列”的方法。也就是说，我希望任何准备好使用消息的消费者都可以使用它们。

我尝试将 queuePrefetch 设置为 0，但它似乎根本不起作用。

    <bean id="prefetchPolicy" class="org.apache.activemq.ActiveMQPrefetchPolicy">
      <property name="queuePrefetch" value="0"/>
    </bean>

    <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
      <constructor-arg index="0" value="tcp://localhost:61616" />
      <property name="prefetchPolicy" ref="prefetchPolicy"/>
    </bean>

以下是我的 JMS 容器的设置:

        <bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
            <property name="connectionFactory" ref="connectionFactory"/>
            <property name="destination" ref="defaultDestination" />
            <property name="messageListener" ref="messageListener" />
            <property name="concurrentConsumers" value="2" />
        </bean>

Answer 1

我发现了问题。我在两个不同的地方两次声明了相同的 bean 。加载的第二个 bean 没有将预取设置为 0，因此它不起作用。

我发布的上述设置有效!

谢谢!