设置ActiveMQ Artemis路由类型，Spring Boot JmsListener为客户端

Question

@JmsListener(destination="price.address::price.2.queue", selector="JMSType='test'")
public void testReceiver1(String msg) {
    System.out.println("1 " + msg); 
}
@JmsListener(destination="price.address::price.2.queue")
public void testReceiver2(String msg) {
    System.out.println("2 " + msg); 
}

理想情况下，这两个客户机/监听器应该能够使用anycast订阅，因此其中一个或两个都可以指定选择器并获取这些消息。

但是当它们连接时，就会创建选播队列。所以我尝试将地址添加到我的经纪人中，如下所示：

  <addresses>
    <address name="price.address">
            <multicast/>
    </address>
  </addresses>

这似乎什么也没起作用。将创建选播队列。

我还尝试将两个侦听器都设置为直接指向主题/地址（不使用FQQN)，但仍然会出现一个选播路由类型--一个名为“price.address”的队列。

我不确定所有这些数据最终将如何使用，所以我试图尽可能灵活地提供。我知道大部分根本用不上，至少一时半会儿用不上。

我有另一个项目，其中大部分传入数据没有使用。我设置了一个地址和显式队列，并为此设置了过滤器，每个需要过滤数据的客户机都有一个。这很好，但现在的不同之处在于，我需要客户机能够连接并指定筛选器（选择器）以获取所需的数据，并且只接收新的传入消息。

我不确定这是JMS客户机的Artemis问题还是Sprint Boot@JMSListener问题。

Artemis 2.17 Spring Boot 2.5

Answer 1

假设您希望客户端能够连接并且：

• 为所需数据指定选择器
• 只接收新传入的消息

这意味着您希望使用JMS主题。