如何查找多播队列?

Question

在broker.xml中配置以下主题/队列：

<address name="Topic1">
<multicast>
<queue name="Queue1"/>
<queue name="Queue2"/>
</multicast>
</address>

如何为队列 1/队列 2 创建生产者以发送消息？我正在使用ActiveMQ Artemis 2.6.3。

使用以下方式创建连接工厂，连接和队列查找

Hashtable<String, Object> properties = new Hashtable<>();
properties.put("connectionFactory.ConnectionFactory", (tcp://localhost:61618,tcp://localhost:61616)?ha=true&retryInterval=3000&reconnectAttempts=-1&initialConnectAttempts=10&maxRetryInterval=3000&clientFailureCheckPeriod=1000);
properties.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
InitialContext jndiContext = new InitialContext(properties);
ConnectionFactory connFactory = (ConnectionFactory) jndiContext.lookup(connectionFactory);
Connection connection = connFactory.createConnection(userName, password);
Session session = connection.createSession(true,javax.jms.Session.AUTO_ACKNOWLEDGE);
//Using following way looking up Multicast Queue2 on Address Topic1
Destination dest = new ActiveMQTopic("Topic1::Queue2");
MessageProducer producer = session.createProducer(dest);
producer.send(message, Message.DEFAULT_DELIVERY_MODE, Message.DEFAULT_PRIORITY, msgTTL);

完成上述代码更改并尝试发送消息后，消息不会发送到队列"Queue2">

Answer 1

通常，您希望根据需要选择正确的路由类型。选项是：

任播

• ：提供点对点语义(例如JMS队列);发送到该地址的消息仅路由到一个任播队列
多播
• ：提供发布-订阅语义(例如JMS主题);发送到该地址的消息被路由到所有多播队列

你有一个名为Topic的地址，其中包含 2 个组播队列 -Queue1&Queue2。因此，发送给Topic的消息将同时发送到Queue1和Queue2。如果只想将消息发送到一个队列，则可以考虑使用其他配置(例如，具有任播队列的地址)。

但是，如果您发现出于任何原因确实需要现有配置，那么您可以通过语法<address>::<queue>使用完全限定的队列名称(即 FQQN)发送消息。我看到您已经在尝试这样做，例如：

Destination dest = new ActiveMQTopic("Topic1::Queue2");

但是，您使用的ActiveMQ Artemis版本不支持生产者的FQQN。要使用此功能，我建议您至少升级到 2.7.0 或理想情况下升级到最新版本 2.17.0。

Answer 2

与 Spring 和 Artemis 2.7.0 @justin相同的解决方案：

JmsTemplate jmsTemplate = new JmsTemplate(new 
ActiveMQConnectionFactory("tcp://localhost:61616"));
//this is the important part
jmsTemplate.setPubSubDomain(true);
jmsTemplate.convertAndSend("Topic1::Queue2", "hello");