时间戳

首页 > 解决方案 > 具有持久共享订阅的 Artemis JUnit

spring-boot - 具有持久共享订阅的 Artemis JUnit

问题描述

我正在使用artemis-junit依赖项

testImplementation("org.apache.activemq:artemis-junit")

使用 Spring Boot 2+，我有 2 个具有以下配置的 JMS 侦听器：

destination = "my.topic"
clientId = "sharedApp1" 
subscription = "mySharedSub"
durable = "true"
shared = "true"

我想验证共享订阅是否有效，但是当我运行 JUnit 测试时，第二次监听会抛出

ActiveMQDuplicateMetaDataException[errorType=DUPLICATE_METADATA message=AMQ229035: Metadata jms-client-id=sharedApp1 had been set already]

堆栈跟踪：

javax.jms.JMSException: Failed to create session factory
at org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.createConnectionInternal(ActiveMQConnectionFactory.java:886) ~[artemis-jms-client-2.13.0.jar:2.13.0]
at org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.createConnection(ActiveMQConnectionFactory.java:299) ~[artemis-jms-client-2.13.0.jar:2.13.0]
at org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.createConnection(ActiveMQConnectionFactory.java:294) ~[artemis-jms-client-2.13.0.jar:2.13.0]
at org.springframework.jms.support.JmsAccessor.createConnection(JmsAccessor.java:196) ~[spring-jms-5.2.7.RELEASE.jar:5.2.7.RELEASE]
at org.springframework.jms.listener.AbstractJmsListeningContainer.createSharedConnection(AbstractJmsListeningContainer.java:412) ~[spring-jms-5.2.7.RELEASE.jar:5.2.7.RELEASE]
at org.springframework.jms.listener.AbstractJmsListeningContainer.establishSharedConnection(AbstractJmsListeningContainer.java:380) ~[spring-jms-5.2.7.RELEASE.jar:5.2.7.RELEASE]
at org.springframework.jms.listener.DefaultMessageListenerContainer.establishSharedConnection(DefaultMessageListenerContainer.java:818) ~[spring-jms-5.2.7.RELEASE.jar:5.2.7.RELEASE]

这是设计使然（开发人员帮助），因为我在同一个 JVM 中运行？还是我做错了什么？

标签： spring-bootactivemq-artemis

解决方案

错误是设计使然。让多个并发 JMS 客户端使用相同的客户端 ID 是违反 JMS 规范的。JMS 2 规范的第 6.1.2 节这样说：

客户端标识符的目的是将连接及其对象与提供者代表客户端维护的状态相关联。根据定义，由客户端标识符标识的客户端状态一次只能由一个客户端“使用”。JMS 提供者必须防止并发执行的客户端使用它。

请记住，对于 JMS 2 共享持久订阅，客户端 ID 是可选的。JMS 2 规范的第 4.2.2 节规定：

共享的持久订阅由名称和可选的客户端标识符标识，并且可能有多个消费者对象使用其中的消息。

推荐阅读