如何接收在artemis控制台中创建的多播类型队列消息

Question

>

下载Artemis2.13.0，预先创建组播地址测试，然后在此地址上创建组播队列123，使用控制台向123队列发送1消息

使用IDEA创建springboot项目，pom文件导入以下依赖项

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-artemis</artifactId>
        </dependency>

        <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-jms</artifactId>
        <version>5.2.5.RELEASE</version>
        <scope>compile</scope>
    </dependency>


    <dependency>
        <groupId>org.apache.activemq</groupId>
        <artifactId>artemis-jms-client</artifactId>
        <version>2.13.0</version>
        <scope>compile</scope>
    </dependency>

pplication.properties添加配置

spring.artemis.mode=native
spring.artemis.host=localhost
spring.artemis.port=61616
spring.artemis.user=test
spring.artemis.password=123456

spring.jms.pub-sub-domain=true

创建消费者以接收在队列123中预先创建的消息

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

@Component
public class Consumer{
    @JmsListener(destination="test::123")
    public void consumerMessage(String text){
        System.out.println("从queue队列收到的回复信息为:"+text);
    }

}

我无法接收该消息，使用2.13.0artemis-jms-client将出现以下错误消息

Setup of JMS message listener invoker failed for destination 'test::123' - trying to recover. Cause: AMQ229019: Queue 123 already exists on address test

Artemis创建一个服务器，并且不修改代理文件。

Answer 1

为JMS用例预先创建多播队列是相当不正常的。通常，您只需使用地址的名称作为应用程序中JMS主题的名称，然后代理将自动在该地址上创建一个队列来表示应用程序的JMS订阅，然后应用程序将接收发送到该地址的任何消息。将JMS概念映射到核心代理实现的语义将在文档中进一步讨论。

但是，如果您的用例迫使您预先创建多播队列，那么您可以使用完全限定的队列名称（即FQQN)，它遵循

:: 的形式来访问该队列。因此，在您的示例中，您将使用test::123，例如：

@JmsListener(destination = "test::123")
public void receiveQueueMsg(String msg) {
    System.out.println("收到的消息为：" + msg);
}

FQQN语法和功能将在文档中进一步讨论。

为此，我修改了ActiveMQ Artemis附带的spring-boot-integration示例，以使用普通JMS客户机（即，不是AMQP JMS客户机），并将FQQN与多播队列一起使用，所有操作都按预期进行。