JMS active mq 一条消息并发消费
JMS active mq one message to be consumed concurrently
我正在使用 apache active mq，并且有一个用于多个操作的公共使用者。对于每个消费者，代码执行大约需要 15-20 分钟，我希望如果在生成另一条消息之间，那么两条消息应该并行使用，尽管它们只有一个消费者。
在您定义了 DefaultMessageListenerContainer bean 的应用程序上下文中，您可以添加 "concurrentConsumers" 属性 并定义您想要的并发消费者数量，以收听您的消息队列。
下面是相同的示例
<bean id="jmsMailContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="concurrentConsumers">
<value>100</value>
</property>
<property name="connectionFactory" ref="connectionFactory"/>
<property name="destination" ref="mailDestination"/>
<property name="messageListener" ref="jmsMailConsumer"/>
</bean>
我正在使用 apache active mq，并且有一个用于多个操作的公共使用者。对于每个消费者，代码执行大约需要 15-20 分钟，我希望如果在生成另一条消息之间，那么两条消息应该并行使用，尽管它们只有一个消费者。
在您定义了 DefaultMessageListenerContainer bean 的应用程序上下文中，您可以添加 "concurrentConsumers" 属性 并定义您想要的并发消费者数量，以收听您的消息队列。
下面是相同的示例
<bean id="jmsMailContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="concurrentConsumers">
<value>100</value>
</property>
<property name="connectionFactory" ref="connectionFactory"/>
<property name="destination" ref="mailDestination"/>
<property name="messageListener" ref="jmsMailConsumer"/>
</bean>