[
https://issues.apache.org/activemq/browse/AMQ-1220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=43461#action_43461
]
Jaya Srinivasan commented on AMQ-1220:
--------------------------------------
Hi James
We are using ActiveMq 5.0.0 and we see this exception quite often in our logs.
After this exception the connection between the Broker and the client is broken
and we have to reconnect the client. We do have auto-reconnect code in the
client so its not a big problem but it would be nice if this didn't happen on
the broker side.
We usually see this exception after a certain number of messages have been sent
and it happens even when the Inactivity monitor has been disabled and when
broker is still up and running.
the connect URL we are using is as follows:
tcp://<mymachinename>:61616?jms.useAsyncSend=true&jms.dispatchAsync=true&wireFormat.maxInactivityDuration=-1
> 2007-04-05 08:46:47,241 [ActiveMQ Transport: tcp://mymachinename:61616] WARN
> org.apache.activemq.ActiveMQConnection - Async exception with no exception
> listener: java.io.EOFException
> ---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: AMQ-1220
> URL: https://issues.apache.org/activemq/browse/AMQ-1220
> Project: ActiveMQ
> Issue Type: Bug
> Components: Transport
> Affects Versions: 4.1.0
> Environment: Windows XP SP2, Eclipse IDE, Java 1.6/1.5_10/ ActiveMQ
> 4.1.1/Spring 2.0.2 (jmsTemplate)
> Reporter: Howard Freeman
>
> 2007-04-05 08:46:47,241 [ActiveMQ Transport: tcp://mymachinename:61616] WARN
> org.apache.activemq.ActiveMQConnection - Async exception with no exception
> listener: java.io.EOFException
> java.io.EOFException
> at java.io.DataInputStream.readInt(Unknown Source)
> 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(Unknown Source)
> This error occurs after the synchronous messaging is complete and successful.
> It occurs after about 5 minutes of the application finishing the receive.
> The error is not seen when the same send/receive methods are looped
> continuously. The application is a very simple send and receive application
> that uses Serialization methods for send and receive of objects.
> // Sample send/receive
> client.send(Request);
> response = (Response) client.receive();
> Spring code used for send:
> // Send Request
> jmsTemplate.convertAndSend(requestQueue, req, new
> MessagePostProcessor()
> {
> public Message postProcessMessage(Message message) throws
> JMSException
> {
> message.setJMSCorrelationID(myMessageID);
> return message;
> }
> });
> Spring code used for receive:
> // Wait for Synchronous Response
> // Use a Message Selector to only receive responses to the request you
> // sent
> String resSelectorId = "JMSCorrelationID='" +
> getCurrentJMSMessageID() + "'";
> Response resp = (Response)
> jmsTemplate.receiveSelectedAndConvert(responseQueue,
> resSelectorId);
> Here is the shared-context.xml for the connectionFactory:
> <?xml version="1.0" encoding="UTF-8"?>
> <beans xmlns="http://www.springframework.org/schema/beans";
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
> xsi:schemaLocation="http://www.springframework.org/schema/beans
>
> http://www.springframework.org/schema/beans/spring-beans.xsd";>
>
> <bean id="RequestQueue" class="org.apache.activemq.command.ActiveMQQueue">
> <constructor-arg value="RequestQueue"/>
> </bean>
>
> <bean id="ResponseQueue"
> class="org.apache.activemq.command.ActiveMQQueue">
> <constructor-arg value="ResponseQueue"/>
> </bean>
>
> <!-- A Pooled Based JMS Provider -->
> <bean id="jmsFactory"
> class="org.apache.activemq.pool.PooledConnectionFactory">
> <property name="connectionFactory">
> <bean class="org.apache.activemq.ActiveMQConnectionFactory">
> <property name="brokerURL"
> value="tcp://mymachinename:61616"/>
> </bean>
> </property>
> </bean>
>
> </beans>
> I am sure that it is something I have failed to configure correctly since I
> am very new the activeMQ product.
> Thanks for your time and effort!
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
