У меня проблема с ActiveMQ и Spring CachingConnectionFactory
. Я устанавливаю их так:
<!-- A connection to ActiveMQ -->
<bean id="myConnectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="${jms.url}"/>
<property name="userName" value="${jms.username}"/>
<property name="password" value="${jms.password}"/>
</bean>
<!-- A cached connection to wrap the ActiveMQ connection -->
<bean id="myCachedConnectionFactory"
class="org.springframework.jms.connection.CachingConnectionFactory">
<property name="targetConnectionFactory" ref="myConnectionFactory"/>
<property name="sessionCacheSize" value="10"/>
<property name="reconnectOnException" value="true"/>
</bean>
<!-- A destination in ActiveMQ -->
<bean id="myDestination"
class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg value="${jms.queue}" />
</bean>
<!-- A JmsTemplate instance that uses the cached connection and destination -->
<bean id="myProducerTemplate"
class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="myCachedConnectionFactory"/>
<property name="defaultDestination" ref="myDestination"/>
</bean>
jms.url
использует отказоустойчивый транспорт:
failover:(tcp://firstbox:6166,tcp://secondbox:6166)?timeout=3000
Проблема, с которой я сталкиваюсь, заключается в том, что если один ящик выйдет из строя, мы должны начать отправлять сообщения на другом, но, похоже, он все еще использует старое соединение (каждая отправка истекает). Если я перезапущу программу, она снова подключится и все работает.
Насколько я понимаю, ActiveMQConnectionFactory
должен исправить себя (повторно подключиться к новому ящику), а JmsTemplate
должен каждый раз запрашивать новое соединение, так что все должно быть в порядке. Мне интересно, может ли CachingConnectionFactory
делать что-то плохое (кеширование производителя, который общается со старым сервером?).
Я пропустил что-то, что мне нужно сделать здесь? Моя настройка кажется довольно нормальной, но я не могу найти никого, у кого была бы эта проблема.