You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Denis Abramov (JIRA)" <ji...@apache.org> on 2008/02/22 07:12:14 UTC

[jira] Created: (AMQ-1592) Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long

Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long
----------------------------------------------------------------------------------------------------------

                 Key: AMQ-1592
                 URL: https://issues.apache.org/activemq/browse/AMQ-1592
             Project: ActiveMQ
          Issue Type: Bug
          Components: Broker
    Affects Versions: 4.1.1
         Environment: RedHat Linux
            Reporter: Denis Abramov
            Priority: Blocker


>From a different poster:

I'm programming some kind of messaging program that sends messages in sparse frequency using activeMQ. 
I got exceptions like following and connection between client and activeMQ server is closed. 
---------- 
11:20:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
11:20:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
11:20:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
11:20:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
11:21:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
11:21:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
11:21:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
11:21:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
11:21:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
11:21:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
11:22:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
11:22:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
11:22:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
11:22:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
11:22:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
11:22:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
11:23:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
11:23:09,202 DEBUG [InactivityMonitor] No message received since last read check for tcp://aaa.aaa.aaa/111.111.111.111:61616! Throwing InactivityIOException. 
11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
        at org.apache.activemq.transport.InactivityMonitor$4.run(InactivityMonitor.java:108) 
11:23:09,218 DEBUG [TcpTransport] Stopping transport tcp://some.domain.com/som.ip.he.re:61616 
11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: java.net.SocketException: socket closed 
java.net.SocketException: socket closed 
        at java.net.SocketInputStream.socketRead0(Native Method) 
        at java.net.SocketInputStream.read(Unknown Source) 
        at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50) 
        at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58) 
        at java.io.DataInputStream.readInt(Unknown Source) 
        at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:268) 
        at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192) 
        at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184) 
        at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172) 
        at java.lang.Thread.run(Unknown Source) 
------------ 



-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


[jira] Commented: (AMQ-1592) Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long

Posted by "Denis Abramov (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/AMQ-1592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=41366#action_41366 ] 

Denis Abramov commented on AMQ-1592:
------------------------------------

I am using activemq-all-5.1-SNAPSHOT.jar and still get this error: 

2008-02-19 11:44:25,768 (ActiveMQConnection.java:1453) WARN  org.apache.activemq.ActiveMQConnection - Async exception with no exception listener: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long. 
org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long. 
        at org.apache.activemq.transport.InactivityMonitor.readCheck(InactivityMonitor.java:101) 
        at org.apache.activemq.transport.InactivityMonitor.access$000(InactivityMonitor.java:35) 
        at org.apache.activemq.transport.InactivityMonitor$1.run(InactivityMonitor.java:51) 
        at edu.emory.mathcs.backport.java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:431) 
        at edu.emory.mathcs.backport.java.util.concurrent.FutureTask.runAndReset(FutureTask.java:198) 
        at edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:189) 
        at edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:213) 
        at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650) 
        at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675) 
        at java.lang.Thread.run(Thread.java:595) 




> Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long
> ----------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-1592
>                 URL: https://issues.apache.org/activemq/browse/AMQ-1592
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 4.1.1
>         Environment: RedHat Linux
>            Reporter: Denis Abramov
>            Priority: Blocker
>
> From a different poster:
> I'm programming some kind of messaging program that sends messages in sparse frequency using activeMQ. 
> I got exceptions like following and connection between client and activeMQ server is closed. 
> ---------- 
> 11:20:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:20:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:20:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:20:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:21:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:21:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:21:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:21:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:21:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:21:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:22:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:22:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:22:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:22:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:22:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:22:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:23:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:23:09,202 DEBUG [InactivityMonitor] No message received since last read check for tcp://aaa.aaa.aaa/111.111.111.111:61616! Throwing InactivityIOException. 
> 11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
> org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
>         at org.apache.activemq.transport.InactivityMonitor$4.run(InactivityMonitor.java:108) 
> 11:23:09,218 DEBUG [TcpTransport] Stopping transport tcp://some.domain.com/som.ip.he.re:61616 
> 11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: java.net.SocketException: socket closed 
> java.net.SocketException: socket closed 
>         at java.net.SocketInputStream.socketRead0(Native Method) 
>         at java.net.SocketInputStream.read(Unknown Source) 
>         at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50) 
>         at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58) 
>         at java.io.DataInputStream.readInt(Unknown Source) 
>         at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:268) 
>         at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192) 
>         at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184) 
>         at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172) 
>         at java.lang.Thread.run(Unknown Source) 
> ------------ 

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


[jira] Commented: (AMQ-1592) Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long

Posted by "Marco Buss (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/AMQ-1592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=41369#action_41369 ] 

Marco Buss commented on AMQ-1592:
---------------------------------

Try such a connector URL.

tcp://jmshost:61616?wireFormat.maxInactivityDuration=0

> Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long
> ----------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-1592
>                 URL: https://issues.apache.org/activemq/browse/AMQ-1592
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 4.1.1
>         Environment: RedHat Linux
>            Reporter: Denis Abramov
>            Priority: Blocker
>
> From a different poster:
> I'm programming some kind of messaging program that sends messages in sparse frequency using activeMQ. 
> I got exceptions like following and connection between client and activeMQ server is closed. 
> ---------- 
> 11:20:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:20:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:20:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:20:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:21:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:21:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:21:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:21:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:21:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:21:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:22:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:22:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:22:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:22:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:22:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:22:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:23:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:23:09,202 DEBUG [InactivityMonitor] No message received since last read check for tcp://aaa.aaa.aaa/111.111.111.111:61616! Throwing InactivityIOException. 
> 11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
> org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
>         at org.apache.activemq.transport.InactivityMonitor$4.run(InactivityMonitor.java:108) 
> 11:23:09,218 DEBUG [TcpTransport] Stopping transport tcp://some.domain.com/som.ip.he.re:61616 
> 11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: java.net.SocketException: socket closed 
> java.net.SocketException: socket closed 
>         at java.net.SocketInputStream.socketRead0(Native Method) 
>         at java.net.SocketInputStream.read(Unknown Source) 
>         at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50) 
>         at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58) 
>         at java.io.DataInputStream.readInt(Unknown Source) 
>         at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:268) 
>         at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192) 
>         at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184) 
>         at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172) 
>         at java.lang.Thread.run(Unknown Source) 
> ------------ 

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


[jira] Assigned: (AMQ-1592) Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long

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

Rob Davies reassigned AMQ-1592:
-------------------------------

    Assignee: Rob Davies

> Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long
> ----------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-1592
>                 URL: https://issues.apache.org/activemq/browse/AMQ-1592
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 4.1.1
>         Environment: RedHat Linux
>            Reporter: Denis Abramov
>            Assignee: Rob Davies
>            Priority: Blocker
>             Fix For: 5.1.0
>
>
> From a different poster:
> I'm programming some kind of messaging program that sends messages in sparse frequency using activeMQ. 
> I got exceptions like following and connection between client and activeMQ server is closed. 
> ---------- 
> 11:20:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:20:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:20:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:20:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:21:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:21:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:21:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:21:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:21:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:21:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:22:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:22:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:22:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:22:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:22:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:22:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:23:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:23:09,202 DEBUG [InactivityMonitor] No message received since last read check for tcp://aaa.aaa.aaa/111.111.111.111:61616! Throwing InactivityIOException. 
> 11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
> org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
>         at org.apache.activemq.transport.InactivityMonitor$4.run(InactivityMonitor.java:108) 
> 11:23:09,218 DEBUG [TcpTransport] Stopping transport tcp://some.domain.com/som.ip.he.re:61616 
> 11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: java.net.SocketException: socket closed 
> java.net.SocketException: socket closed 
>         at java.net.SocketInputStream.socketRead0(Native Method) 
>         at java.net.SocketInputStream.read(Unknown Source) 
>         at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50) 
>         at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58) 
>         at java.io.DataInputStream.readInt(Unknown Source) 
>         at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:268) 
>         at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192) 
>         at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184) 
>         at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172) 
>         at java.lang.Thread.run(Unknown Source) 
> ------------ 

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


[jira] Commented: (AMQ-1592) Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long

Posted by "Ron Gavlin (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/AMQ-1592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=42439#action_42439 ] 

Ron Gavlin commented on AMQ-1592:
---------------------------------

Is there any way the fix for this issue can be backported to the 5.0.x branch? Unfortunately, I will not be able to upgrade to AMQ 5.1 for some period of time and this issue is quite problematic for me.

> Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long
> ----------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-1592
>                 URL: https://issues.apache.org/activemq/browse/AMQ-1592
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 4.1.1
>         Environment: RedHat Linux
>            Reporter: Denis Abramov
>            Assignee: Rob Davies
>            Priority: Blocker
>             Fix For: 5.1.0
>
>
> From a different poster:
> I'm programming some kind of messaging program that sends messages in sparse frequency using activeMQ. 
> I got exceptions like following and connection between client and activeMQ server is closed. 
> ---------- 
> 11:20:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:20:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:20:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:20:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:21:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:21:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:21:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:21:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:21:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:21:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:22:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:22:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:22:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:22:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:22:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:22:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:23:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:23:09,202 DEBUG [InactivityMonitor] No message received since last read check for tcp://aaa.aaa.aaa/111.111.111.111:61616! Throwing InactivityIOException. 
> 11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
> org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
>         at org.apache.activemq.transport.InactivityMonitor$4.run(InactivityMonitor.java:108) 
> 11:23:09,218 DEBUG [TcpTransport] Stopping transport tcp://some.domain.com/som.ip.he.re:61616 
> 11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: java.net.SocketException: socket closed 
> java.net.SocketException: socket closed 
>         at java.net.SocketInputStream.socketRead0(Native Method) 
>         at java.net.SocketInputStream.read(Unknown Source) 
>         at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50) 
>         at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58) 
>         at java.io.DataInputStream.readInt(Unknown Source) 
>         at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:268) 
>         at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192) 
>         at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184) 
>         at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172) 
>         at java.lang.Thread.run(Unknown Source) 
> ------------ 

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


[jira] Issue Comment Edited: (AMQ-1592) Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long

Posted by "Ron Gavlin (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/AMQ-1592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=42439#action_42439 ] 

rgavlin edited comment on AMQ-1592 at 4/24/08 11:15 PM:
-----------------------------------------------------------

Please ignore.

      was (Author: rgavlin):
    Is there any way the fix for this issue can be backported to the 5.0.x branch? Unfortunately, I will not be able to upgrade to AMQ 5.1 for some period of time and this issue is quite problematic for me.
  
> Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long
> ----------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-1592
>                 URL: https://issues.apache.org/activemq/browse/AMQ-1592
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 4.1.1
>         Environment: RedHat Linux
>            Reporter: Denis Abramov
>            Assignee: Rob Davies
>            Priority: Blocker
>             Fix For: 5.1.0
>
>
> From a different poster:
> I'm programming some kind of messaging program that sends messages in sparse frequency using activeMQ. 
> I got exceptions like following and connection between client and activeMQ server is closed. 
> ---------- 
> 11:20:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:20:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:20:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:20:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:21:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:21:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:21:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:21:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:21:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:21:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:22:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:22:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:22:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:22:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:22:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:22:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:23:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:23:09,202 DEBUG [InactivityMonitor] No message received since last read check for tcp://aaa.aaa.aaa/111.111.111.111:61616! Throwing InactivityIOException. 
> 11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
> org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
>         at org.apache.activemq.transport.InactivityMonitor$4.run(InactivityMonitor.java:108) 
> 11:23:09,218 DEBUG [TcpTransport] Stopping transport tcp://some.domain.com/som.ip.he.re:61616 
> 11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: java.net.SocketException: socket closed 
> java.net.SocketException: socket closed 
>         at java.net.SocketInputStream.socketRead0(Native Method) 
>         at java.net.SocketInputStream.read(Unknown Source) 
>         at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50) 
>         at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58) 
>         at java.io.DataInputStream.readInt(Unknown Source) 
>         at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:268) 
>         at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192) 
>         at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184) 
>         at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172) 
>         at java.lang.Thread.run(Unknown Source) 
> ------------ 

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


[jira] Commented: (AMQ-1592) Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long

Posted by "Denis Abramov (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/AMQ-1592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=41378#action_41378 ] 

Denis Abramov commented on AMQ-1592:
------------------------------------

Already tried "tcp://jmshost:61616?wireFormat.maxInactivityDuration=0". What happens in this case is that the client is still dropped but there is no exception. The client just stops receiving messages - so isn't much better :-)

Thanks for the advice

> Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long
> ----------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-1592
>                 URL: https://issues.apache.org/activemq/browse/AMQ-1592
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 4.1.1
>         Environment: RedHat Linux
>            Reporter: Denis Abramov
>            Priority: Blocker
>
> From a different poster:
> I'm programming some kind of messaging program that sends messages in sparse frequency using activeMQ. 
> I got exceptions like following and connection between client and activeMQ server is closed. 
> ---------- 
> 11:20:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:20:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:20:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:20:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:21:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:21:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:21:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:21:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:21:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:21:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:22:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:22:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:22:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:22:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:22:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:22:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:23:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:23:09,202 DEBUG [InactivityMonitor] No message received since last read check for tcp://aaa.aaa.aaa/111.111.111.111:61616! Throwing InactivityIOException. 
> 11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
> org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
>         at org.apache.activemq.transport.InactivityMonitor$4.run(InactivityMonitor.java:108) 
> 11:23:09,218 DEBUG [TcpTransport] Stopping transport tcp://some.domain.com/som.ip.he.re:61616 
> 11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: java.net.SocketException: socket closed 
> java.net.SocketException: socket closed 
>         at java.net.SocketInputStream.socketRead0(Native Method) 
>         at java.net.SocketInputStream.read(Unknown Source) 
>         at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50) 
>         at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58) 
>         at java.io.DataInputStream.readInt(Unknown Source) 
>         at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:268) 
>         at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192) 
>         at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184) 
>         at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172) 
>         at java.lang.Thread.run(Unknown Source) 
> ------------ 

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


[jira] Commented: (AMQ-1592) Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long

Posted by "Denis Abramov (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/AMQ-1592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=41365#action_41365 ] 

Denis Abramov commented on AMQ-1592:
------------------------------------

Thanks for your fast reply, Rob. 

I tried activeMQ 5.1. 
The connection alive time is longer than 5.0 version that I used before. 
But it still closes the connection after some while. 

I attach the exception logs below. 
Is there any configuration value for idle timeout? 
----- 
18:34:04,249 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
18:34:14,249 DEBUG [InactivityMonitor] 30000 ms elapsed since last read check. 
18:34:14,249 DEBUG [InactivityMonitor] No message received since last read check for tcp://some.domain.com/127.0.0.1:61616! Throwing InactivityIOException. 
18:34:14,249 WARN  [ActiveMQConnection] Async exception with no exception listener: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/127.0.0.1:61616 
org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/127.0.0.1:61616 
        at org.apache.activemq.transport.InactivityMonitor$4.run(InactivityMonitor.java:142) 
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source) 
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) 
        at java.lang.Thread.run(Unknown Source) 
18:34:14,249 DEBUG [TcpTransport] Stopping transport tcp://some.domain.com/127.0.0.1:61616 
18:34:14,265 WARN  [ActiveMQConnection] Async exception with no exception listener: java.net.SocketException: socket closed 
java.net.SocketException: socket closed 
        at java.net.SocketInputStream.socketRead0(Native Method) 
        at java.net.SocketInputStream.read(Unknown Source) 
        at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50) 
        at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58) 
        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:203) 
        at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:195) 
        at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:183) 
        at java.lang.Thread.run(Unknown Source) 





> Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long
> ----------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-1592
>                 URL: https://issues.apache.org/activemq/browse/AMQ-1592
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 4.1.1
>         Environment: RedHat Linux
>            Reporter: Denis Abramov
>            Priority: Blocker
>
> From a different poster:
> I'm programming some kind of messaging program that sends messages in sparse frequency using activeMQ. 
> I got exceptions like following and connection between client and activeMQ server is closed. 
> ---------- 
> 11:20:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:20:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:20:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:20:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:21:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:21:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:21:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:21:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:21:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:21:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:22:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:22:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:22:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:22:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:22:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:22:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:23:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:23:09,202 DEBUG [InactivityMonitor] No message received since last read check for tcp://aaa.aaa.aaa/111.111.111.111:61616! Throwing InactivityIOException. 
> 11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
> org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
>         at org.apache.activemq.transport.InactivityMonitor$4.run(InactivityMonitor.java:108) 
> 11:23:09,218 DEBUG [TcpTransport] Stopping transport tcp://some.domain.com/som.ip.he.re:61616 
> 11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: java.net.SocketException: socket closed 
> java.net.SocketException: socket closed 
>         at java.net.SocketInputStream.socketRead0(Native Method) 
>         at java.net.SocketInputStream.read(Unknown Source) 
>         at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50) 
>         at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58) 
>         at java.io.DataInputStream.readInt(Unknown Source) 
>         at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:268) 
>         at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192) 
>         at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184) 
>         at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172) 
>         at java.lang.Thread.run(Unknown Source) 
> ------------ 

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


[jira] Resolved: (AMQ-1592) Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long

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

Rob Davies resolved AMQ-1592.
-----------------------------

    Fix Version/s: 5.1.0
       Resolution: Fixed

> Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long
> ----------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-1592
>                 URL: https://issues.apache.org/activemq/browse/AMQ-1592
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 4.1.1
>         Environment: RedHat Linux
>            Reporter: Denis Abramov
>            Assignee: Rob Davies
>            Priority: Blocker
>             Fix For: 5.1.0
>
>
> From a different poster:
> I'm programming some kind of messaging program that sends messages in sparse frequency using activeMQ. 
> I got exceptions like following and connection between client and activeMQ server is closed. 
> ---------- 
> 11:20:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:20:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:20:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:20:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:21:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:21:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:21:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:21:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:21:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:21:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:22:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:22:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:22:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:22:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:22:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:22:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:23:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:23:09,202 DEBUG [InactivityMonitor] No message received since last read check for tcp://aaa.aaa.aaa/111.111.111.111:61616! Throwing InactivityIOException. 
> 11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
> org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
>         at org.apache.activemq.transport.InactivityMonitor$4.run(InactivityMonitor.java:108) 
> 11:23:09,218 DEBUG [TcpTransport] Stopping transport tcp://some.domain.com/som.ip.he.re:61616 
> 11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: java.net.SocketException: socket closed 
> java.net.SocketException: socket closed 
>         at java.net.SocketInputStream.socketRead0(Native Method) 
>         at java.net.SocketInputStream.read(Unknown Source) 
>         at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50) 
>         at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58) 
>         at java.io.DataInputStream.readInt(Unknown Source) 
>         at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:268) 
>         at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192) 
>         at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184) 
>         at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172) 
>         at java.lang.Thread.run(Unknown Source) 
> ------------ 

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


[jira] Commented: (AMQ-1592) Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long

Posted by "Joseph H. Montanez (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/AMQ-1592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=43692#action_43692 ] 

Joseph H. Montanez commented on AMQ-1592:
-----------------------------------------

Can we get a solution to this made available in 4.1.1?

> Inactivity Monitor: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long
> ----------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-1592
>                 URL: https://issues.apache.org/activemq/browse/AMQ-1592
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 4.1.1
>         Environment: RedHat Linux
>            Reporter: Denis Abramov
>            Assignee: Rob Davies
>            Priority: Blocker
>             Fix For: 5.1.0
>
>
> From a different poster:
> I'm programming some kind of messaging program that sends messages in sparse frequency using activeMQ. 
> I got exceptions like following and connection between client and activeMQ server is closed. 
> ---------- 
> 11:20:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:20:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:20:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:20:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:21:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:21:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:21:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:21:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:21:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:21:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:22:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:22:09,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:22:24,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:22:39,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:22:39,202 DEBUG [InactivityMonitor] Message received since last read check, resetting flag: 
> 11:22:54,202 DEBUG [InactivityMonitor] Message sent since last write check, resetting flag 
> 11:23:09,202 DEBUG [InactivityMonitor] No message sent since last write check, sending a KeepAliveInfo 
> 11:23:09,202 DEBUG [InactivityMonitor] No message received since last read check for tcp://aaa.aaa.aaa/111.111.111.111:61616! Throwing InactivityIOException. 
> 11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
> org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: some.domain.com/som.ip.he.re:61616 
>         at org.apache.activemq.transport.InactivityMonitor$4.run(InactivityMonitor.java:108) 
> 11:23:09,218 DEBUG [TcpTransport] Stopping transport tcp://some.domain.com/som.ip.he.re:61616 
> 11:23:09,218 WARN  [ActiveMQConnection] Async exception with no exception listener: java.net.SocketException: socket closed 
> java.net.SocketException: socket closed 
>         at java.net.SocketInputStream.socketRead0(Native Method) 
>         at java.net.SocketInputStream.read(Unknown Source) 
>         at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50) 
>         at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58) 
>         at java.io.DataInputStream.readInt(Unknown Source) 
>         at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:268) 
>         at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192) 
>         at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184) 
>         at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172) 
>         at java.lang.Thread.run(Unknown Source) 
> ------------ 

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.