activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ron55test <rkn...@gmail.com>
Subject Transport failed. Getting java.io.EOFException
Date Mon, 02 Apr 2007 01:14:43 GMT

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.


Mime
View raw message