用于多个jms服务器的单个jms消费者
我使用分布式jms队列，weblogic是我的应用服务器。在我的集群环境中部署了三个jms服务器。例如，生产者只是使用队列名称jndi lookup 'udq '来发送消息。现在，我已经为每个jms服务器关联了一个消费者，并且能够消费消息，到目前为止没有问题。
这里有一个问题，我是否可以让一个消费者使用来自3个jms服务器的消息。weblogic允许使用以下语法对目标查找进行jndi命名：@
qsession1 = qcon1.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
qsession2 = qcon2.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
qsession3 = qcon3.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
queue1 = (Queue)ctx.lookup("JMSServer-1@UDQ");
queue2 = (Queue)ctx.lookup("JMSServer-2@UDQ");
queue3 = (Queue)ctx.lookup("JMSServer-3@UDQ");
qreceiver1 = qsession1.createReceiver(queue1);
qreceiver2 = qsession2.createReceiver(queue2);
qreceiver3 = qsession3.createReceiver(queue3);
qreceiver1.setMessageListener(this);
qreceiver2.setMessageListener(this);
qreceiver3.setMessageListener(this);
qcon1.start();
qcon2.start();
qcon3.start();
我只有一个OnMessage为上述消费者实现。这不起作用。任何建议请...
共有2个答案
您可以使用“队列转发”功能。来自wls 10.3的在线留档：
通过在管理控制台中配置“转发延迟”属性，队列成员可以将消息转发给其他队列成员，该属性在默认情况下是禁用的。该属性定义了具有消息但没有消费者的分布式队列成员在将其消息转发给具有消费者的其他队列成员之前等待的时间（秒）
这里有一个链接：http://docs.oracle.com/cd/E13222_01/wls/docs103/jms/dds.html#wp1260816
您可以通过管理每个队列来配置此功能。
不可以，不能让使用者从多个 JMS 服务器接收消息。使用者只能从一个 JMS 服务器接收消息。您需要创建多个使用者才能从多个 JMS 服务器接收消息。
-
问题内容： 我有一个JMS客户端，它正在生成消息并通过JMS队列发送到其唯一的使用者。 我想要的是不止一个消费者收到这些消息。我想到的第一件事是将队列转换为主题，以便现有用户和新用户都可以订阅并将相同的消息传递给他们。 显然，这将涉及在生产者和消费者方面修改当前的客户代码。 我还要查看其他选项，例如创建第二个队列，这样就不必修改现有的使用者。我相信这种方法有很多优点，例如（如果我错了，请纠正我）在
-
我有一个由第三方发布的JMS队列。我想在不同的机器上设置多个使用者，只有一台特定机器的使用者确认该队列上的消息。简而言之，如果特定机器的使用者没有接收到消息，那么该消息不应从队列中删除。这是可以实现的吗？
-
JMS队列有2个消费者，同步和异步Java应用程序进程等待响应。1）同步应用程序发送请求，并根据JMS相关ID等待响应60秒。2）异步线程将不断侦听同一队列。
-
下面是我们设置的简化/示意图拓扑 每个节点（服务器）都是一个独立的（无集群）jboss应用服务器(Jboss-as7)，包括消息传递服务器。 消息传递服务器部署许多JMS队列。 每个任务服务器为每个队列部署一个MDB，每个队列有许多使用者。 所有消息生产者使用相同的入站适配器，所有消息使用者使用相同的出站适配器。事实上，所有前端节点都是完全相同的（与所有服务器节点相同，配置相同，部署的工件相同）。
-
我有一个使用ActiveMQ的JMS生产者/订阅者的简单Spring应用程序，配置如下： 我试过所有可能的解决办法，但没有一个奏效。我们非常感谢任何帮助
-
我正在使用Spring靴和活动MQ设置一个持久的JMS主题使用者。我能够使用Spring靴@JmsListener注释来使一切正常工作（作为耐用消费者成功运行）。但是，因为我想动态创建侦听器，所以我尝试使用 JmsListener 配置接口来创建它们。 使用主题“消费者”下面的代码可以成功地创建和使用消息。但是，问题是它创造的消费者并不持久。我在工厂中将clientId、setSubscripti