用例:测试一个系统,它将消息发送到一个真正的JMS队列,这个队列(在测试设置中)不会被任何其他程序读出。(我不想模仿JMS队列,以使测试环境尽可能接近生产环境。出于同样的原因,在客户端为消息设置“生存时间”也不是一个有效的解决方案。)
如何做一个队列,你把它作为一个主题的别名,没有人听它?
例如:
def qalias(MYQUEUE) target(DUMMYTOPIC) targtype(TOPIC)
def topic(DUMMYTOPIC) topicstr(DUMMYTOPIC)
然后您可以将其放入队列,它将成为一个发布,如果没有人监听队列,它将消失。例如,AMQSPUT MYQUEUE QM
可以很好地工作。
我有一个spring jms应用程序,目前使用ibm mq server进行队列管理。我们计划将中间件改为rabbitmq,以获得更好的性能并有效地控制它,但希望保持spring jms代码的原样。我遵循了以下链接中提到的所有步骤。https://www.rabbitmq.com/jms-client.html
如何从weblogic JMS队列中清除/删除消息 我的是一个集群环境,在服务中使用。 获取以下异常。
我安装了Rabbitmqadmin,并能够列出所有的交换和队列。如何使用Rabbitmqadmin或Rabbitmqctl删除所有队列。
我试图在WebLogic10r3服务器上调试一个web应用程序主机。该应用程序通过Java消息驱动bean接收来自外部IBM JMS队列(classname:)的输入。 我写了一个小的测试应用程序来连接到队列并发送测试消息。目前的问题是测试消息会生成异常,并且不知何故它会被放回队列中,并一次又一次地循环。这会产生大量异常,使日志不可读。 代码概述了JMS生产者:
我正在使用Spring4.3.5.Release和ActiveMQ5.14.3来处理消息队列。 下面是我的单元测试: 这个测试工作得很好,并且消息会正确地进入队列! 因为单元测试是事务性的,所以我希望当测试结束时,消息会从队列中回滚,但似乎并非如此。 我知道这是一个“集成”测试,因为它实际上是接触ActiveMQ服务器并将消息放入队列。 那么,我如何使这真正事务性,使我刚刚放在队列上的消息真的在它
问题内容: 我对ThreadPoolExecutor有一个非常简单的问题。我有以下情况:我必须使用队列中的对象,为它们创建适当的工作程序任务,然后将其提交给ThreadPoolExecutor。这很简单。但是在关闭情况下, 许多 工作人员可能会排队等待执行。由于这些任务之一可能正在运行一个小时,而且我希望相对快速地正常关闭应用程序,因此我想从ThreadPoolExecutor中丢弃所有排队的任务