具有持久共享订阅的 Artemis JUnit答案

【问题标题】：Artemis JUnit with durable shared subscription具有持久共享订阅的 Artemis JUnit
【发布时间】：2020-11-18 03:29:52
【问题描述】：

我正在使用 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-boot activemq-artemis

【解决方案1】：

在我看来，您正在同一个 JVM 中运行测试，并且由于以下验证 (org.apache.activemq.artemis.jms.client.ActiveMQConnection) 是不可能的：

private void validateClientID(ClientSession validateSession, String clientID)
     throws InvalidClientIDException, ActiveMQException {
  try {
     validateSession.addUniqueMetaData(JMS_SESSION_CLIENT_ID_PROPERTY, clientID);
  } catch (ActiveMQException e) {
     if (e.getType() == ActiveMQExceptionType.DUPLICATE_METADATA) {
        throw new InvalidClientIDException("clientID=" + clientID + " was already set into another connection");
     } else {
        throw e;
     }
  }
}

【讨论】：

【解决方案2】：

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

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

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

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

【讨论】：

感谢您的回答，但我正在查看 stackoverflow.com/questions/58679284/… 您引用以下内容：规范在第 8.3.4 节中对共享持久订阅说了同样的基本内容：确定共享持久订阅由客户端指定的名称和客户端标识符（如果已设置）。如果在首次创建共享持久订阅时设置了客户端标识符，则随后希望在该共享持久订阅上创建消费者的客户端必须使用相同的客户端标识符。
所以在删除 clientId 之后测试现在成功了，但我认为按照规范我应该允许我所做的事情。尽管如此，不使用 clientId 似乎更通用，因为它甚至可以由不同的应用程序（即不同的 clientIds）共享。但请在我将答案标记为解决方案之前澄清这一点。谢谢贾斯汀。
实际上，规范不允许您所做的事情。我已经参照规范的适用部分澄清了我对这一点的回答。
我在您链接的另一个答案中引用的规范中的一点只是说明 if 您在创建订阅时设置了客户端 ID，那么您需要使用稍后重新连接到订阅时使用相同的客户端 ID。这并不是说多个消费者可以使用同一个客户端 ID。