我正在将Spring JMS与ActiveMQ用作代理,并在Tomcat上运行该应用程序。我有一个队列,比方说队列。在我的Web应用程序中,每当启动我的Web应用程序时,我已经有一个MessageListener在运行。唯一的事情是,我想同步添加某种队列使用者。我已经尝试使用JmsTemplate等。但是,当我的两个使用者(侦听器异步和使用者同步)都启动并且触发.receive()方法时,发送到队列的消息总是被一直在线的消息侦听器吸收。自网络应用启动以来。超时结束后,同步接收器完全不消耗任何消息。
但是,当我注释掉messageListener时,同步客户运行良好。
我仍然是新手,你们中的任何人有什么方法可以使我想要的成为可能吗?谢谢!对不起,我的英语不好 :(
<bean id="someQueue" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg index="0" value="TEST.QUEUE?consumer.priority=10" />
</bean>
然后将其设置为您的侦听器/接收器Bean:
<bean id="someReceiver" class="blah.blah.SomeReceiver">
<property name="destination" ref="someQueue" />
<property name="jmsTemplate" ref="jmsTemplate" />
</bean>
这样可以解决您的问题吗?
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句