Does anyone know how to make sure queues reconnect with ActiveMQ 3.1?
Basically, I've got 3 machines that attempt to periodically be message
producers. One of the 3 machines is selected and sends messages via
activemq to all the machines.
However, at some point the machines inevitably stop sending messages, and I
see this in the error log:
2006-05-02 00:30:00,035 [INFO] [Thread-25]
org.activemq.broker.impl.BrokerContainerImpl - Adding new client:
ID:MessageProducingMachine-36491-1144387297431-43717:0 on transport:
VmTransportChannel: null
2006-05-02 00:30:00,046 [INFO] [Thread-27]
org.activemq.broker.impl.BrokerContainerImpl - Adding new client:
ID:MessageProducingMachine-36491-1144387297431-43724:0 on transport:
VmTransportChannel: null
2006-05-02 00:30:00,296 [INFO] [Thread-25]
org.activemq.broker.impl.BrokerContainerImpl - Removing client:
ID:MessageProducingMachine-36491-1144387297431-43717:0 on transport:
VmTransportChannel: null
2006-05-02 00:30:00,555 [INFO] [Thread-27]
org.activemq.broker.impl.BrokerContainerImpl - Removing client:
ID:MessageProducingMachine-36491-1144387297431-43724:0 on transport:
VmTransportChannel: null
All these errors are on the current maching producing messages.
My settings are:
<beans>
<broker>
<connector>
<serverTransport uri="vm://localhost"/>
</connector>
<connector>
<serverTransport uri="tcp://localhost:60000"/>
</connector>
<discoveryAgent>
<multicastDiscovery channelName="productionChannel"
uri="multicast://230.0.0.255:60001" />
</discoveryAgent>
<discoveryNetworkConnector/>
<persistence>
<vmPersistence/>
</persistence>
</broker>
</beans>
With the Spring config:
<bean id="broker" class="org.activemq.spring.BrokerFactoryBean">
<property name="config" value="classpath:activeMQ.xml"/>
</bean>
<bean id="jcaContainer" class="org.activemq.jca.JCAContainer">
<property name="workManager">
<bean class="org.activemq.work.SpringWorkManager">
<property name="scheduledMaximumPoolSize" value="100"/>
<property name="syncMaximumPoolSize" value="100"/>
<property name="startMaximumPoolSize" value="100"/>
</bean>
</property>
<property name="resourceAdapter">
<bean class="org.activemq.ra.ActiveMQResourceAdapter">
<property name="serverUrl" value="vm://localhost"/>
</bean>
</property>
</bean>
<bean id="connectionFactory"
class="org.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="vm://localhost"/>
</bean>
I've also seen this problem when trying to upgrade to 3.2.2, so I haven't
really bothered. Am I missing something here? Any help would be much
appreciated.
--
View this message in context:
http://www.nabble.com/Queue-connectivity-t1547104.html#a4202885
Sent from the ActiveMQ - User forum at Nabble.com.
