Mule - JMS (ActiveMQ) переподключение

Question

Это мой поток мулов 1:

HTTP > Payload String > Logger > JMS /normalqueue

Первый поток имеет error handling:

File (Написать файл для каждого обработанного сообщения)

Поток 2:

JMS /normalqueue > Logger

Поток восстановления (вызывается с помощью скрипта Groovy):

File (Read file) > File to String > Flow reference (To First Flow again)

Это XML из мула:

<http:listener-config name="HTTP_Listener_Configuration" host="0.0.0.0" port="8081" doc:name="HTTP Listener Configuration"/>
<jms:activemq-connector name="Active_MQ" username="admin" password="admin" brokerURL="tcp://192.168.198.131:61616" validateConnections="true" doc:name="Active MQ" persistentDelivery="true">
    <reconnect blocking="false" frequency="6000"/>
</jms:activemq-connector>
<file:connector name="File" writeToDirectory="C:\errors" autoDelete="true" streaming="true" validateConnections="true" doc:name="File"/>
<flow name="lab-file-catchFlow">
    <http:listener config-ref="HTTP_Listener_Configuration" path="/" doc:name="HTTP"/>
    <set-payload value="#[message.payloadAs(java.lang.String)]" doc:name="Set Payload"/>
    <logger message="Started message: #[message.payloadAs(java.lang.String)]" level="INFO" doc:name="Logger"/>
    <jms:outbound-endpoint queue="activemq" connector-ref="Active_MQ" doc:name="JMS">
        <jms:transaction action="ALWAYS_BEGIN"/>
    </jms:outbound-endpoint>
    <catch-exception-strategy doc:name="Catch Exception Strategy">
        <file:outbound-endpoint path="C:\errors" connector-ref="File" responseTimeout="10000" doc:name="File"/>
    </catch-exception-strategy>
</flow>
<flow name="flow-recovery" initialState="stopped" processingStrategy="synchronous">
    <file:inbound-endpoint path="C:\errors" connector-ref="File" responseTimeout="10000" doc:name="File"/>
    <file:file-to-string-transformer doc:name="File to String"/>
    <logger message=" Recovery message: #[message.payloadAs(java.lang.String)]" level="ERROR" doc:name="Logger"/>
    <flow-ref name="lab-file-catchFlow" doc:name="Flow Reference"/>
</flow>
<flow name="lab-file-catchFlow2" processingStrategy="synchronous">
    <jms:inbound-endpoint queue="activemq" connector-ref="Active_MQ" doc:name="JMS"/>
    <logger message="#[message.payloadAs(java.lang.String)]" level="INFO" doc:name="Logger"/>
</flow>
<flow name="lab-file-catchFlow1" >
    <http:listener config-ref="HTTP_Listener_Configuration" path="/modify" doc:name="HTTP"/>
    <scripting:component doc:name="Groovy">
        <scripting:script engine="Groovy"><![CDATA[            if(muleContext.registry.lookupFlowConstruct('flow-recovery').isStopped())
             {
              muleContext.registry.lookupFlowConstruct('flow-recovery').start();
              return 'Started';
             } else
             {
             muleContext.registry.lookupFlowConstruct('flow-recovery').stop();
             return 'Stopped';
             }]]></scripting:script>
    </scripting:component>
    <set-payload value="#[message.payloadAs(java.lang.String)]" doc:name="Set Payload"/>
    <logger message="#[message.payloadAs(java.lang.String)]" level="INFO" doc:name="Logger"/>
</flow>

1. Я прекращаю обслуживание с ActiveMQ, он хранит файл с сообщениями от обработки ошибок, и я получаю типичную ошибку:

Не удается обработать событие, так как "Active_MQ" остановлен

2. Затем я запускаю ActiveMQ service снова и запустите процесс восстановления с помощью отличного сценария. Этот поток восстанавливает все сообщения, преобразует их в строку и возвращает к первому потоку для запроса.

Проблема в том, что mule не определяет, когда служба снова работает, мне нужно перезапустить проект mule, чтобы обнаружить его.

Есть ли способ автоматического определения, когда activeMQ снова работает с Mule?

Answer 1

От <reconnect-forever/>Мул будет продолжать пытаться подключиться к ActiveMQ

<jms:activemq-connector name="Active_MQ" username="admin" password="admin" brokerURL="tcp://192.168.198.131:61616" validateConnections="true" doc:name="Active MQ" persistentDelivery="true">
    <reconnect-forever/>
</jms:activemq-connector>