1个队列中的同步和异步消息接收器(带有ActiveMQ的Spring)JMS API

尼科

我正在将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] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

在Masstransit框架上的Azure队列接收器中获取Api响应

带有 Windows API 的两个 cpp 文件的消息队列

带有内部消息队列的前端REST API?

Pulseaudio C API:创建一个空接收器

使异步API同步

带有ActiveMQ的Spring JMS:如何异步读取选择性消息

带有JAX-RX的REST API从jsp页面中的表单发送和接收解析的JSON

GCP:无法通过gcloud / API创建项目接收器

带有队列的长期运行的REST API

如何使用 Nodejs 和 javaScript 在 API 中实现带有消息的条件?

XML和API中带有C#代码的错误消息

带有同步 API 下载的 Swift HUD

JMS 与 Spring Boot、发送器和接收器在同一个包上:它有什么用?

接收器执行中的事件总线和异步

带有Rabbit Binder的Spring Cloud Stream-源/接收器队列名称不匹配

如何理解JMS中的“同步”和“异步”消息传递?

带有Spring JMS的ActiveMQ-如何发送NONPERSISTENT消息?

通过JMS API检查HornetQ中是否存在队列

广播接收器未从Google SMS检索器API接收SMS

JMS消息接收器按消息文本进行过滤

JMS队列接收消息?

同步2个api API调用的结果

Google Cloud Speech API:同步和异步识别之间有什么区别?

Spring Boot JMS:当JMS接收器发生内部应用程序错误时,如何不丢失jms消息

广播接收器,始终接收API级别+26的广播(即使在后台)

结合同步和异步操作的C ++ API设计

Scala中带有接收器的功能类型

Go中带有接收器的方法声明

带有 2 个源的 Spring Data Flow 馈送一个处理器/接收器