I've set up a master slave configuration with the client using the failover
transport to connect to the available brokers.

With the master slave set-up, even if the master does not fail, I keep
getting this exception frequently:

2007-03-30 18:18:45,769 0.1:61617 INFO  FailoverTransport     Transport
failed, attempting to automatically reconnect due to: java.io.EOFException
java.io.EOFException
        at java.io.DataInputStream.readInt(DataInputStream.java:358)
        at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:156)
        at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:136)
        at java.lang.Thread.run(Thread.java:595)

BTW,
--I'm using Spring and activemq
--Event though I get this exception, my messages are consumed without any
problem
--I'm using Spring's DefaultMessageListenerContainer as the listener
--Here is my configuration

        <bean id="connectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
              <property name="brokerURL">
               
<value>failover:(tcp://localhost:61616,tcp://localhost:61617)</value>
              </property>
              <property name="dispatchAsync">
                <value>true</value>
              </property>
              <property name="useAsyncSend">
                <value>false</value>
              </property>
        </bean>

        <!-- Spring JMS Template -->
        <bean id="jmsQueueTemplate"
class="org.springframework.jms.core.JmsTemplate">
                  <property name="connectionFactory">
                        <ref bean="connectionFactory"/>
                  </property>
                  <property name="defaultDestination">
                        <ref bean="destination" />
                  </property>
                  <property name="receiveTimeout">
                        <value>-1</value>
                  </property>
            <property name="messageConverter" ref="simpleMessageConverter" />
        </bean>

        <bean id="simpleMessageConverter" 
class="org.springframework.jms.support.converter.SimpleMessageConverter">
        </bean>

        <bean id="jmsSender" class="com.abc.jump.jdm.service.jms.JMSSenderImpl">
          <property name="jmsTemplate" ref="jmsQueueTemplateDashboard" />
        </bean>

        <bean id="jmsConsumer" 
class="com.abc.jump.jdm.service.jms.JMSConsumerImpl"
singleton="true">
                <property name="deploymentTaskService" 
ref="deploymentTaskService" />
                <property name="userService"><ref 
bean="userService"/></property>
        </bean>

        <bean id="jmsReceiver" 
class="com.abc.jump.jdm.service.jms.JMSReceiverImpl"
>
                  <property name="jmsTemplate" ref="jmsQueueTemplate" />
                  <property name="jmsConsumer" ref="jmsConsumer"></property>
        </bean>

        <bean id="destination" 
class="org.apache.activemq.command.ActiveMQQueue">
            <constructor-arg value="ActiveMQQueue" />
        </bean>

        <bean id="listenerContainer"
class="org.springframework.jms.listener.DefaultMessageListenerContainer">
                  <property name="concurrentConsumers" value="1"/>
              <property name="connectionFactory" ref="connectionFactory" />
              <property name="destination" ref="destination" />
              <property name="messageListener" ref="jmsReceiver" />
                  <property name="receiveTimeout" value="-1"/>
        </bean>

Any help will be appreciated.  Thanks
-Ron

-- 
View this message in context: 
http://www.nabble.com/Transport-failed.--Getting-java.io.EOFException-tf3503231s2354.html#a9783954
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Reply via email to