activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tdeast <teastl...@gmail.com>
Subject Queue connectivity
Date Wed, 03 May 2006 01:45:16 GMT

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.


Mime
View raw message