如何修复ActiveMQ持久订阅引发“持久消费者已在使用”错误

Question

我正在尝试编写一个基本的 ActiveMQ 客户端来侦听一个主题。我正在使用Spring启动活动MQ。我有一个基于各种教程构建的实现，它使用默认Jms列表容器工厂，但是我在使其正常工作时遇到了一些问题。

@Configuration
@EnableJms
public class JmsConfig {
    @Bean
    public DefaultJmsListenerContainerFactory jmsContainerFactory(ConnectionFactory connectionFactory,
                                                                  DefaultJmsListenerContainerFactoryConfigurer configurer) {
        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        factory.setConcurrency("3-10");
        factory.setConnectionFactory(connectionFactory);

        configurer.configure(factory, connectionFactory);

       factory.setSubscriptionDurable(true);
       factory.setClientId("someUniqueClientId");

       return factory;
   }
}

@JmsListener(destination="someTopic", containerFactory="jmsContainerFactory", subscription="someUniqueSubscription")
public void onMessage(String msg) {
    ...
}

一切都很好，直到我尝试获得一个持久的订阅。当我这样做时，我发现在容器工厂中设置了客户机id，我得到了一个关于如何在共享连接上设置客户机id的错误。

＜code＞原因：共享连接的代理不支持setClientID调用。改为在SingleConnectionFactory上设置“clientId”属性。

当我将代码更改为在连接工厂上设置客户端id时（它是一个封装ActiveMQConnectionFactory的CachingConnectionFactory），服务成功启动，读取两条消息，然后开始一致输出此错误：

< code >为目标“someTopic”设置JMS消息侦听器调用程序失败-正在尝试恢复。原因:持久使用者正用于客户端:someUniqueClientId和订阅名称:somuniquesubscription

我继续收到消息，但也有错误混杂在日志中。这似乎可能是一个问题，但我真的不清楚如何解决它。

我确实有一个天真的实现，没有任何Spring代码，直接使用ActiveMQConnectionFactory，似乎很乐意使用持久消费者（但它有自己不同的问题）。无论如何，我不认为另一方面缺乏对持久连接的支持。

我希望在这方面有更多经验的人能帮我弄清楚这个错误是不是我可以忽略的，或者我需要做些什么来解决它。

谢谢

Answer 1

JMS 1.1(因为您正在使用ActiveMQ 5.x，所以您正在使用它)不支持共享持久订阅。因此，当您使用< code > set concurrency(" 3-10 ")并且Spring试图创建

1. 使用＜code＞setConcurrency（“1”）
2. 切换到支持JMS 2.0的ActiveMQ Artemis，并调用setSubscriptionShared（true）