使用JMS的多播地址的Artemis持久订阅

Question

使用JMS，我想为主题(多播地址(创建一些持久订阅。在一个双订阅的情况下，它是有效的，但在更多的情况下不起作用，并且会出现错误。

这些是我的听众：也许属性没有正确填写？

@JmsListener(destination = "VirtualTopic.test", id = "c1", subscription = "Consumer.A.VirtualTopic.test", containerFactory = "queueConnectionFactory")
public void receive1(String m) {
}

@JmsListener(destination = "VirtualTopic.test", id = "c2", subscription = "Consumer.B.VirtualTopic.test", containerFactory = "queueConnectionFactory")    
public void receive2(String m) {
}

这是listenerFactory：我不确定最后一个属性。

@Bean
public DefaultJmsListenerContainerFactory queueConnectionFactory() {
DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
factory.setConnectionFactory(connectionFactory());
factory.setClientId("brokerClientId");
factory.setSubscriptionDurable(true);
factory.setSubscriptionShared(true);       **<-- needed for my case?**
return factory;
}
@Bean
public ActiveMQConnectionFactory connectionFactory() {
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerUrl);
return connectionFactory;
}

当我设置"factory.setSubscriptionShared(true(；"时，这些是错误日志：

2020-04-17 11:23:44.485  WARN 7900 --- [enerContainer-3] o.s.j.l.DefaultMessageListenerContainer  : Setup of JMS message listener invoker failed for destination 'VirtualTopic.test' - trying to recover. Cause: org.apache.activemq.ActiveMQSession.createSharedDurableConsumer(Ljavax/jms/Topic;Ljava/lang/String;Ljava/lang/String;)Ljavax/jms/MessageConsumer; 
2020-04-17 11:23:44.514 ERROR 7900 --- [enerContainer-3] o.s.j.l.DefaultMessageListenerContainer  : Could not refresh JMS Connection for destination 'VirtualTopic.test' - retrying using FixedBackOff{interval=5000, currentAttempts=0, maxAttempts=unlimited}. Cause: Broker: d1 - Client: brokerClientId already connected from /127.0.0.1:59979

Answer 1

正如JMS规范所指出的，只有一个具有相同ID的客户端可以连接。显然，您对所有连接都使用相同的客户端ID，即：

factory.setClientId("brokerClientId");

请尝试而不是设置客户端ID，看看情况如何。

此外，请确保您使用的JMS客户端实现实际上支持JMS 2.0(例如ActiveMQ Artemis核心JMS客户端(。