You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Howard Freeman (JIRA)" <ji...@apache.org> on 2007/04/05 17:45:34 UTC

[jira] Created: (AMQ-1220) 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

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.


[jira] Commented: (AMQ-1220) 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

Posted by "Jaya Srinivasan (JIRA)" <ji...@apache.org>.
    [ 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.


[jira] Resolved: (AMQ-1220) 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

Posted by "James Strachan (JIRA)" <ji...@apache.org>.
     [ https://issues.apache.org/activemq/browse/AMQ-1220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

James Strachan resolved AMQ-1220.
---------------------------------

    Resolution: Won't Fix

AFAIK this is just a warning message created due the the underlying socket being terminated; its not an actual problem or bug.

I suspect the broker is just closing an unused connection down because it is no longer being used (it could be the operating system closing the socket too).

You can enable/configure the inactivity timeout on the broker via this link....

http://activemq.apache.org/configuring-wire-formats.html


> 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.


[jira] Commented: (AMQ-1220) 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

Posted by "James Strachan (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/AMQ-1220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#action_39266 ] 

James Strachan commented on AMQ-1220:
-------------------------------------

BTW let us know if you think this is still a problem & we can reopen

> 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.