Spring Message Consumer становится недоступным после ActiveMQ Master / Slave

Question

У меня проблема с приложением Spring JMS Listener, которое прослушивает topi c.

Всякий раз, когда в ActiveMQ происходит переход от главного к подчиненному, мой идентификатор потребителя меняется с «активных постоянных подписчиков» на «автономных постоянных подписчиков», как сообщает веб-консоль ActiveMQ. Если я снова перезапущу свое потребительское приложение, оно станет активным в разделе «Активные постоянные подписчики» Я не уверен, что не так с моей конфигурацией Spring Listener.

<bean id="amqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> 
    <property name="brokerURL" value="failover:(tcp://xxx01:61616,tcp://xxx02:61626)?randomize=false&amp;initialReconnectDelay=100&amp;maxReconnectDelay=100&amp;maxReconnectAttempts=30"/> 
    <property name="clientID" value="DevTest" />
</bean>

<bean id="connectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
    <constructor-arg ref="amqConnectionFactory" />
    <property name="reconnectOnException" value="true" />
</bean>

<bean id="messageReceiver" class="com.example.jms.TestMessageListener">
</bean>

<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <property name="connectionFactory" ref="connectionFactory" />
    <property name="destinationName" value="TESTTOPIC" />
    <property name="messageListener" ref="messageReceiver" />
    <property name="subscriptionDurable" value="true" />
    <property name="pubSubDomain" value="true" />
</bean>

Answer 1

У меня была похожая проблема с ActiveMQ Artemis, и я помог удалить параметры подключения.

У меня работает: (tcp://xxx.xxx.xxx.xxx:61616,tcp:/xxx.xxx.xxx.xxx:61617)

Давайте попробуем:

failover:(tcp://xxx01:61616,tcp://xxx02:61626)