activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "James Strachan" <james.strac...@gmail.com>
Subject Re: Transport failed. Getting java.io.EOFException
Date Mon, 02 Apr 2007 08:00:29 GMT
See http://activemq.apache.org/jmstemplate-gotchas.html

On 4/2/07, ron55test <rknr55@gmail.com> wrote:
>
> 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.
>
>


-- 

James
-------
http://radio.weblogs.com/0112098/

Mime
View raw message