如何找出JMS主题的所有订阅者都已答复?
使用HornetQ(在JBoss AS 6.0中)，我想设置一个JMS主题，多个客户端可以订阅. 生产者定期向该主题发送一条带有回复目的地的消息，所有订阅者都应回复该目的地. 我遇到的问题是我不确定如何检查所有订阅者是否确实答复过. 一种解决方案是，每个订户在订阅后首先向该主题发送一条消息及其详细信息(也许是一些GUID).生产者会记住这些详细信息，并在以后使用它检查是否所有订阅
..
messaging相关内容
WSMQ队列限制
在单个连接和单个会话中可以打开多少个队列是否有限制?我目前可以打开128个队列并将消息发送给它们.如果我尝试打开129，则会出现以下错误... 谢谢 错误: com.ibm.msg.client.jms.DetailedResourceAllocationException: JMSWMQ2008: Failed to open MQ queue 'TestQueue_129'.
..
多线程JMS代码:CLIENT_ACKNOWLEDGE或交易会话
已编辑的问题:我正在研究多线程JMS接收者和发布者代码(独立的多线程Java应用程序). MOM是MQSonic. 从队列接收XML消息，调用存储过程(执行需要70秒)，并在90秒内将响应发送到Topic. 当代理关闭或应用程序按计划关闭时，我需要处理一个条件.也就是在这种情况下，从Queue接收消息并在Java中对其进行处理，与此同时Queue和Topic都将关闭.然后，要处理那些不在队列中且未
..
具有多个使用者但只有一个活动的MQ队列
我们有一个MQ队列，该队列从我们的控制范围之外的外部系统接收消息. 我们的处理传入消息的系统是至关重要的系统，无论如何，都需要启动并运行27x7. 传入消息的处理顺序也不可商议，这意味着我们需要按照它们到达的顺序进行处理. 为确保我们的系统100％可用，我们将系统部署到了能够处理这些消息的一堆物理计算机上. 一旦消息到达我们的系统，我们就建立了一种机制，以确保消息处理不会出现混乱
..
用于多个目标和使用者的Spring配置
我正在使用一个具有一个目的地和一个消费者(消息监听器)的消息监听器容器:
..
从JMS MessageListener发出回滚信号
我一直在使用JMS和ActiveMQ.一切都是奇迹.我不使用弹簧，也不能. 接口javax.jms.MessageListener只有一种方法onMessage.在实现中，有可能会引发异常.如果实际上引发了异常，那么我说该消息未得到正确处理，需要重新尝试.因此，我需要ActiveMQ等待一会儿，然后重试.即，我需要抛出异常来回滚JMS事务. 我该如何完成这种行为? 也许我找不到A
..
如何在jms-spring集成中向消息侦听器bean注入消息选择器?
我正在使用JMS API(通过HornetQ)，并且我正在使用Spring bean作为消息侦听器容器和消息侦听器:
..
如何连接来自JBOSS 4和5的JMS队列?
我有一台运行Jboss 4.2.2和Jboss 5.1.0的服务器.问题在于，第三方无法在不久的将来将其应用程序升级到Jboss 5.1.0，对我们来说这很简单.不幸的是，我们需要从运行在Jboss 4.2.2上的第三方应用程序发送和接收一些JMS消息. 启用JbossMQ和JbossMessaging之间的JMS消息传输的最简单方法是什么? 解决方案 我认为我找到了解决问题的方法.
..
多次插座发射事件
我正在使用socket进行聊天。这是我在nodejs文件中的套接字代码，它运行良好。 外部套接字 io.emit 工作正常，向连接到 conversationId 的所有用户发出消息。 但是 socket.broadcast.emit （当用户使用应用程序时）我用来通知用户，发出（ socket.broadcast.emit ）事件多个倍。为什么会这样？我是否完全错过套接字方法。
..
JMS - 消息选择器如何与多个队列和主题使用者一起工作？
假设您有一个JMS队列，并且多个消费者正在查看队列中的消息。您希望其中一个消费者获得所有特定类型的消息，因此您决定使用消息选择器。 例如，您定义了一个属性，该属性将放入名为的JMS消息头中， targetConsumer 。您应用于消费者的消息选择器 A ，类似于 WHERE targetConsumer ='CONSUMER_A' 。 很明显，消费者A现在只是抓住具有属性集的消息，就
..
如何从不同会话中的临时队列中获取消息
我是jms和activemq的新手。我在activemq中向一个静态队列生成一条消息，并使用getJMSReplyTo回复临时队列。代码如下： ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory（“tcp：// localhost：61616”）; //创建连接 连接连接= conn
..
Idempotency障碍消息传递
最近演示文稿我看到有关 RabbitMQ 提到了使用称为“幂等效障碍”的消息重复数据删除功能。这只是消息混合器的一个奇特的名称，还是更具体的东西。如果是这样，究竟是什么？谷歌搜索产生的结果主要与RabbitMQ有关，几乎没有解释它是什么。 解决方案 Idempotency 是一个函数的行为，其中对函数的输出执行n次函数导致与函数相同的状态表演一次。这在消息传递环境中很有用，因为延迟消息不会
..
Spring-AMQP重新排队消息计数基于JVM吗？
我正在寻找rabbitmq文档，似乎rabbitmq没有处理消息重新传递计数。如果我要手动ACK / NACK消息，我需要将重试计数保留在内存中（例如，通过使用correlationId作为映射中的唯一键），或者通过在消息中设置我自己的标头，并重新传送它（因此将它放在队列的末尾） 但是，这是一个spring处理的情况。具体来说，我指的是RetryInterceptorBuilder.stat
..
使用RabbitMQ发送对象
我明白这个问题在 重复问题使用rabbitmq发送消息而不是字符串而不是结构 如果使用第一种方式执行此操作 第一条路径 我有以下内容跟踪： java.io.EOFException at java.io.ObjectInputStream $ PeekInputStream.readFully（ObjectInputStream.java： 2304） 在java.
..
RabbitMQ：如何指定要发布的队列？
RabbitMQ的频道#basicConsume 方法为我们提供以下参数： channel.basicConsume（queueName，autoAck，consumerTag，noLocal， exclusive，arguments，callback）; 让我们能够告诉RabbitMQ我们想要使用哪个队列。 但是频道#basicPublish 没有这样的等价
..
Kafka Java使用者永远不会收到任何消息
我正在尝试设置一个基本的Java使用者来接收来自Kafka主题的消息。我已按照以下示例进行操作 - https://cwiki.apache.org / confluence / display / KAFKA / Consumer + Group + Example - 并且有以下代码： package org.example .kafka.client; import java
..
MessageMistener和JMS中的Consumer之间有什么区别？
我是 JMS 的新手。据我所知 消费者 能够从队列/主题中选择消息。那你为什么需要 MessageListener ，因为 消费者 将会知道他们何时收到消息？这样的 MessageListener 的实际用途是什么？ 编辑：来自
..
什么是JMS有用？
我正在寻找JMS是一个很好的解决方案的问题的简单例子，也是JMS在这些情况下是一个很好的解决方案的原因。在过去，我只是简单地使用数据库作为将消息从A传递到B的方法，当消息不一定立即被B处理时。 一个假设的例子这样的系统是所有新注册用户应在注册后24小时内收到欢迎电子邮件的地方。为了便于论证，假设DB不记录每个用户注册的时间，而是将每个新用户的引用（外键）存储在pending_email表中。
..
JMS AUTO_ACKNOWLEDGE何时被确认？
我试图谷歌这个，但没有成功。如果我使用 AUTO_ACKNOWLEDGE ，并且我有一个用Java编写的消费者客户端，那么消息何时被确认？我使用 MessageListener ，其中包含 onMessage 方法。确认是在 onMessage 之前还是在 onMessage 之后或在某个其他时间点发送回服务器的？提前感谢任何人都能提供的任何帮助！ 解决方案 请检查一个。 使用 AU
..
高性能JMS消息传递
我阅读了今年UberConf的幻灯片，其中一位发言人提出Spring JMS为您的消息队列系统增加了性能开销的论点，但我没有看到任何证据支持幻灯片。发言者还指出，点对点比传统的“发布 - 订阅”方法更快，因为每条消息只发送一次而不是广播给每个消费者。 我想知道是否有经验丰富的Java消息传递专家可以在这里权衡并澄清一些技术细节： 实际上是否存在使用Spring JMS而不仅仅是纯JMS
..