使用SSH及activemq订阅/发布模式在消费者端怎么实现多线程
<beanid="jmsContainer"class="org.springframework.jms.listener.DefaultMessageListenerC...
<bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="mQConnectionFactory"/>
<property name="destination" ref="destination"/>
<property name="messageListener" ref="messageListener" />
<property name="messageSelector" value="JMSType = 'PGS_SRV'" />
<property name="taskExecutor" ref="taskExecutor"/>
<property name="sessionTransacted" value="true"/>
<property name="concurrentConsumers" value="1" />
<property name="maxConcurrentConsumers" value="6" />
</bean>
如果我按照上述配置会出现相同信息接收六次的问题,请问有没有什么办法使用完后销毁消费者或者有什么办法即能够实现发布订阅多线程且不会相同消息接收N多次 展开
<property name="connectionFactory" ref="mQConnectionFactory"/>
<property name="destination" ref="destination"/>
<property name="messageListener" ref="messageListener" />
<property name="messageSelector" value="JMSType = 'PGS_SRV'" />
<property name="taskExecutor" ref="taskExecutor"/>
<property name="sessionTransacted" value="true"/>
<property name="concurrentConsumers" value="1" />
<property name="maxConcurrentConsumers" value="6" />
</bean>
如果我按照上述配置会出现相同信息接收六次的问题,请问有没有什么办法使用完后销毁消费者或者有什么办法即能够实现发布订阅多线程且不会相同消息接收N多次 展开
1个回答
推荐律师服务:
若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询