Конфигурация повторного подключения Spring MQ JMS

Question

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

Ниже то, что я пытался,

Это конфигурация, что я изначально имел в своем весенне-MQ-JMS-connections.xml

<!-- Spring JMS Queue Connection Factory --> 
     <!-- 
     <bean id="jmsQueueConnectionFactory.7" 
      class="org.springframework.jms.connection.SingleConnectionFactory" > 
      <property name="targetConnectionFactory"> 
       <ref bean="internalJmsQueueConnectionFactory.7"/> 
      </property> 
     </bean> --> 

я заменил это с ниже конфигурацией, введенной «DefaultMessageListenerContainer », который обернет« SingleConnectionFactory ».

<bean id="jmsQueueConnectionFactory.7" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> 
     <property name="connectionFactory"> 
      <ref bean="single.connection.factory.7"/> 
     </property> 

     <property name="recoveryInterval" value="5000"/> 

    </bean> 

    <bean id="single.connection.factory.7" class="org.springframework.jms.connection.SingleConnectionFactory"> 
    <property name="targetConnectionFactory"> 
     <ref bean="internalJmsQueueConnectionFactory.7"/> 
    </property> 
    </bean> 

Но после этого изменения конфигурации я начал получать следующее исключение.

Failed to configure emapi: 
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'senderAgent.7' defined in URL 
[file://localhost/home/qos/qosdata/config/general/emapi/spring-mq-jms-connections.xml]: 
Cannot resolve reference to bean 'jmsQueueTemplate.7' while setting bean property 'jmsTemplate'; 
nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean 
with name 'jmsQueueTemplate.7' defined in URL 
[file://localhost/home/qos/qosdata/config/general/emapi/spring-mq-jms-connections.xml]: 
Cannot resolve reference to bean 'jmsQueueConnectionFactory.7' while setting bean property 'connectionFactory'; 
nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 
'jmsQueueConnectionFactory.7' defined in URL [file://localhost/home/qos/qosdata/config/general/emapi/spring-mq-jms-connections.xml]: 
Invocation of init method failed; nested exception is java.lang.IllegalArgumentException: 
Property 'destination' or 'destinationName' is required 
     at org.springframework.beans.factory.support.BeanDefinitionValueResolver.resolveReference(BeanDefinitionValueResolver.java:275) 
     at org.springframework.beans.factory.support.BeanDefinitionValueResolver.resolveValueIfNecessary(BeanDefinitionValueResolver.java:104) 
     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyPropertyValues(AbstractAutowireCapableBeanFactory.java:1244) 
     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1008) 
     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:470) 
     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory$1.run(AbstractAutowireCapableBeanFactory.java:409) 
     at java.security.AccessController.doPrivileged(Native Method) 

Это говорит требуется «назначения» или «destinationName», я имею дело с унаследованным кодом, не зная, где искать это или я делаю правильно, когда я изменил конфигурацию.

Просьба предложить, если есть лучший способ повторно подключить OpenMQ к приложению, когда соединение брокера прекращается из-за исключения или при его перезапуске. Я также посмотрел на фабрику подключения пружин jms с прослушивателем исключений, но не мог понять.

Answer 1

A DefaultMessageListenerContainer является контейнером слушателя (используется для приема сообщений от брокера), а не фабрики соединений.

Если вы просто используете его в качестве транспортного средства для повторного подключения, ему нужна пустая очередь для «прослушивания».

EDIT: Обновлено в ответ на ваш комментарий ниже.

Рассмотрите возможность использования Spring Integration; он может быть настроен на автоматическое завершение работы; что-то вроде

<int:gateway service interface="foo.Bar" default-request-channel="foo" /> 

<int:channel id="foo"> 
    <int:dispatcher load-balancer="false"/> 
<int:channel/> 

<int-jms:outbound-channel-adapter channel="foo" order="1" ... /> 

<int-file:outbound-channel-adapter channel="foo" order="2" mode="APPEND" ... /> 

По умолчанию диспетчер балансировки нагрузки (циклическое обслуживание) для двух адаптеров путем включения и выключения балансировки нагрузки он всегда будет отправить его в JMS и не к файлу.

Spring Integration также имеет множество функций для обработки ошибок, добавляя советы повторов для адаптера и т.д., и т.д.

Если вы не хотите использовать Spring Integration, вы можете просто сделать что-то вроде ...

try { 
    this.jmsTemplate.send(...); 
} 
catch (Exception e) { 
    writeToFile(...); 
}