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.
