Фабрика соединений закрывается после нескольких отказов

Question

У меня есть кластер JBoss с двумя узлами в режиме общего хранилища HA.

Когда я убиваю живой узел 1, резервный узел 2 становится живым.

Когда я перезагружаю узел 1, благодаря восстановлению после отказа узел 1 становится живым сервером, а узел 2 снова становится сервером резервного копирования.

Но когда я снова убиваю узел 1, узел 2 становится живым сервером, но я получаю следующее исключение:

10:38:46,545 WARN  [org.apache.camel.component.jms.reply.TemporaryQueueReplyManager] (Camel (camel-poc) thread #20 - TemporaryQueueReplyManager[MY_QUEUE]) Exception inside the DMLC for Temporary ReplyTo Queue for destination MY_QUEUE, refreshing ReplyTo destination: javax.jms.JMSException: Could not create a session: IJ000470: You are trying to use a connection factory that has been shut down: java:/JmsXA
        at org.apache.activemq.artemis.ra.ActiveMQRASessionFactoryImpl.allocateConnection(ActiveMQRASessionFactoryImpl.java:895)
        at org.apache.activemq.artemis.ra.ActiveMQRASessionFactoryImpl.createSession(ActiveMQRASessionFactoryImpl.java:520)
        at org.springframework.jms.support.JmsAccessor.createSession(JmsAccessor.java:192)
        at org.springframework.jms.listener.DefaultMessageListenerContainer.access$1400(DefaultMessageListenerContainer.java:124)
        at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.initResourcesIfNecessary(DefaultMessageListenerContainer.java:1186)
        at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1165)
        at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1158)
        at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:1055)
        at java.lang.Thread.run(Thread.java:748)
Caused by: javax.resource.ResourceException: IJ000470: You are trying to use a connection factory that has been shut down: java:/JmsXA
        at org.jboss.jca.core.connectionmanager.AbstractConnectionManager.allocateConnection(AbstractConnectionManager.java:735)
        at org.apache.activemq.artemis.ra.ActiveMQRASessionFactoryImpl.allocateConnection(ActiveMQRASessionFactoryImpl.java:853)
        ... 8 more

И, конечно, я не могу больше использовать эту очередь.

Вот мое определение подсистемы обмена сообщениями (в основном такое же, как определено в конфигурации автономного ха):

    <subsystem xmlns="urn:jboss:domain:messaging-activemq:1.0">
        <server name="default">
            <cluster password="${jboss.messaging.cluster.password:admin123!}"/>
            <management jmx-enabled="true"/>
            <statistics enabled="true"/>
            <shared-store-slave allow-failback="true"/>
            <bindings-directory path="D:\dev\tools\jboss-eap\jboss-eap-7.0.0-ha\shared_jboss\bindings"/>
            <journal-directory path="D:\dev\tools\jboss-eap\jboss-eap-7.0.0-ha\shared_jboss\journal"/>
            <large-messages-directory path="D:\dev\tools\jboss-eap\jboss-eap-7.0.0-ha\shared_jboss\largemessages"/>
            <paging-directory path="D:\dev\tools\jboss-eap\jboss-eap-7.0.0-ha\shared_jboss\paging"/>
            <security-setting name="#">
                <role name="guest" delete-non-durable-queue="true" create-non-durable-queue="true" consume="true" send="true"/>
            </security-setting>
            <address-setting name="#" redistribution-delay="1000" message-counter-history-day-limit="10" page-size-bytes="2097152" max-size-bytes="10485760" expiry-address="jms.queue.ExpiryQueue" dead-letter-address="jms.queue.DLQ"/>
            <http-connector name="http-connector" endpoint="http-acceptor" socket-binding="http"/>
            <http-connector name="http-connector-throughput" endpoint="http-acceptor-throughput" socket-binding="http">
                <param name="batch-delay" value="50"/>
            </http-connector>
            <in-vm-connector name="in-vm" server-id="0"/>
            <http-acceptor name="http-acceptor" http-listener="default"/>
            <http-acceptor name="http-acceptor-throughput" http-listener="default">
                <param name="batch-delay" value="50"/>
                <param name="direct-deliver" value="false"/>
            </http-acceptor>
            <in-vm-acceptor name="in-vm" server-id="0"/>
            <broadcast-group name="bg-group1" connectors="http-connector" jgroups-channel="activemq-cluster"/>
            <discovery-group name="dg-group1" jgroups-channel="activemq-cluster"/>
            <cluster-connection name="my-cluster" discovery-group="dg-group1" connector-name="http-connector" address="jms"/>
            <jms-queue name="ExpiryQueue" entries="java:/jms/queue/ExpiryQueue"/>
            <jms-queue name="DLQ" entries="java:/jms/queue/DLQ"/>
            <jms-queue name="MY_QUEUE" entries="java:/jms/queue/MY_QUEUE"/>
            <connection-factory name="InVmConnectionFactory" entries="java:/ConnectionFactory" connectors="in-vm"/>
            <connection-factory name="RemoteConnectionFactory" reconnect-attempts="-1" block-on-acknowledge="true" ha="true" entries="java:jboss/exported/jms/RemoteConnectionFactory" connectors="http-connector"/>
            <pooled-connection-factory name="activemq-ra" transaction="xa" entries="java:/JmsXA java:jboss/DefaultJMSConnectionFactory" connectors="in-vm"/>
        </server>
    </subsystem>

Это нормальное поведение или что-то неправильно настроено?

РЕДАКТИРОВАТЬ:

Потребитель развертывается на работающем сервере и на сервере резервного копирования. Очередь используется в контексте Camel и определяется в контексте следующим образом:

<jee:jndi-lookup id="jmsConnectionFactory"
    jndi-name="java:jboss/DefaultJMSConnectionFactory" lookup-on-startup="false"
    proxy-interface="javax.jms.ConnectionFactory" />

<bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
    <property name="connectionFactory" ref="jmsConnectionFactory" />
</bean>

<camelContext xmlns="http://camel.apache.org/schema/spring"
    xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:hel="http://cxf.apache.org/wsse/handler/hell"
    trace="true" id="camel-jms-queue">
    <route id="wsProxyRedirection">
        <from uri="cxf:bean:cdcPocProxyWebServiceStartPoint" />
        <to uri="jms:queue:MY_QUEUE" />
    </route>
</camelContext>

Answer 1

Потребитель развертывается на работающем сервере и на сервере резервного копирования.

Развертывание приложения на сервере, где посредник будет активирован и деактивирован во время обычного режима работы (как в случае пары "живое / резервное копирование"), не рекомендуется. Вместо этого рекомендуется сконфигурировать свою пару live/backup и разместить приложение на 3-м сервере, который будет удаленно подключаться к паре live/backup, используя соответствующую конфигурацию HA, которая обеспечит переключение при сбое (т.е. ha=true).

В вашей текущей ситуации весь брокер (а также связанные очереди, фабрики соединений и т. Д.) Развертываются и удаляются, что почти наверняка не является тем, что компоненты Spring могут понять и / или изящно решить.