You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by ron55test <rk...@gmail.com> on 2007/04/02 03:14:43 UTC
Transport failed. Getting java.io.EOFException
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.
Re: Transport failed. Getting java.io.EOFException
Posted by James Strachan <ja...@gmail.com>.
See http://activemq.apache.org/jmstemplate-gotchas.html
On 4/2/07, ron55test <rk...@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/