activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Manuel Teira <mte...@tid.es>
Subject Re: active MQ (Inactivity exceptions)
Date Mon, 19 Feb 2007 08:31:09 GMT
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
<head>
  <meta content="text/html;charset=ISO-8859-1" http-equiv="Content-Type">
  <title></title>
</head>
<body bgcolor="#ffffff" text="#000099">
Hello. <br>
I'm also suffering these kind of inactivity exceptions in my production
environment (an standalone java process with an embedded activemq 4.0.2
broker). Curiously, I always catch this problem during a log write (I
suppose that it's just a matter of probability, as the write operation
is perhaps one of the slower ones):<br>
<br>
<tt>Error writing log '[WARNING][2007/01/31.09:56:25.936][ActiveMQ
Scheduler]Async exception with no exception listener:
org.apache.activemq.transport.InactivityIOException: Channel was
inactive for too long.(Channel was inactive for too long.)'<br>
java.io.InterruptedIOException<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at java.io.FileOutputStream.writeBytes(Native
Method)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at java.io.FileOutputStream.write(Unknown
Source)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at sun.nio.cs.StreamEncoder$CharsetSE.writeBytes(Unknown
Source)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at sun.nio.cs.StreamEncoder$CharsetSE.implFlushBuffer(Unknown
Source)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at sun.nio.cs.StreamEncoder$CharsetSE.implFlush(Unknown
Source)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at sun.nio.cs.StreamEncoder.flush(Unknown
Source)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at java.io.OutputStreamWriter.flush(Unknown
Source)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at java.io.BufferedWriter.flush(Unknown
Source)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
es.tid.planb.core.FileLogWriter$RealFile.put(FileLogWriter.java:140)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at es.tid.planb.core.FileLogWriter.put(FileLogWriter.java:241)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
es.tid.planb.core.RotFileLogWriter.put(RotFileLogWriter.java:99)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at es.tid.planb.core.Logger.write(Logger.java:240)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at es.tid.planb.core.Logger.rWarning(Logger.java:291)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at es.tid.planb.core.Logger.warning(Logger.java:193)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at es.tid.planb.core.PBLogger.warn(PBLogger.java:260)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
org.apache.activemq.ActiveMQConnection.onAsyncException(ActiveMQConnection.java:1453)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
org.apache.activemq.ActiveMQConnection.onException(ActiveMQConnection.java:1459)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:94)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
org.apache.activemq.transport.ResponseCorrelator.onException(ResponseCorrelator.java:110)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:94)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:94)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
org.apache.activemq.transport.WireFormatNegotiator.onException(WireFormatNegotiator.java:128)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
org.apache.activemq.transport.InactivityMonitor.onException(InactivityMonitor.java:149)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
org.apache.activemq.transport.InactivityMonitor.readCheck(InactivityMonitor.java:101)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
org.apache.activemq.transport.InactivityMonitor.access$000(InactivityMonitor.java:35)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
org.apache.activemq.transport.InactivityMonitor$1.run(InactivityMonitor.java:51)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
edu.emory.mathcs.backport.java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:431)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
edu.emory.mathcs.backport.java.util.concurrent.FutureTask.runAndReset(FutureTask.java:198)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:189)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:213)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)<br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at java.lang.Thread.run(Unknown
Source)</tt><br>
<br>
Is there any way to recover from this situation, or better, to avoid it?<br>
Regards.<br>
<br>
<br>
Suchitha Koneru (sukoneru) escribi&oacute;:
<blockquote
 cite="mid5BD9FA70F5EDAC43AB816A5FDE30F6AC03A6A527@xmb-sjc-21a.amer.cisco.com"
 type="cite">
  <pre wrap=""> The inactiviy exceptions also arises , when lot of  messages are sent
at the rate of 4 messages per second. On the forums , some other user
also reported the occurrence of this exception , when messages were sent
at the rate of 30 per second. 
This exception is becoming a show stopper , Please let me know , if I
have to upgrade to another version of active MQ. 
Thanks,
Suchitha.

-----Original Message-----
From: Suchitha Koneru (sukoneru) 
Sent: Wednesday, February 14, 2007 11:27 AM
To: <a class="moz-txt-link-abbreviated" href="mailto:users@activemq.apache.org">users@activemq.apache.org</a>
Subject: active MQ (Inactivity exceptions)

Hello Active MQ Users , 
              I am getting the following  exceptions , when active MQ
channel is not used for a period of time.As a result of it , the socket
for connection is getting closed.
 
Feb 14, 2007 10:37:28 AM org.apache.activemq.ActiveMQConnection
onAsyncException
WARNING: Async exception with no exception listener:
org.apache.activemq.transport.InactivityIOException:
active for too long.
org.apache.activemq.transport.InactivityIOException: Channel was
inactive for too long.
        at
org.apache.activemq.transport.InactivityMonitor.readCheck(InactivityMoni
tor.java:101)
        at
org.apache.activemq.transport.InactivityMonitor.access$000(InactivityMon
itor.java:35)
        at
org.apache.activemq.transport.InactivityMonitor$1.run(InactivityMonitor.
<a class="moz-txt-link-freetext" href="java:51">java:51</a>)
        at
edu.emory.mathcs.backport.java.util.concurrent.Executors$RunnableAdapter
.call(Executors.java:4
        at
edu.emory.mathcs.backport.java.util.concurrent.FutureTask.runAndReset(Fu
tureTask.java:198)
        at
edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecut
or$ScheduledFutureTask
heduledThreadPoolExecutor.java:189)
        at
edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecut
or$ScheduledFutureTask
hreadPoolExecutor.java:213)
        at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker
.runTask(ThreadPoolExe
 
        at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker
.run(ThreadPoolExecuto
        at java.lang.Thread.run(Thread.java:595)

Feb 14, 2007 10:37:33 AM org.apache.activemq.ActiveMQConnection
onAsyncException
WARNING: 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(SocketInputStream.java:129)
        at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBuffere
dInputStream.java:48)
        at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBuffere
dInputStream.java:55)
        at java.io.DataInputStream.readInt(DataInputStream.java:353)
        at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.jav
a:274)
        at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142
)
        at java.lang.Thread.run(Thread.java:595)

The version of active MQ jars , which Iam using are :

*	activemq-core-4.0.1.jar 
*	backport-util-concurrent-2.1.jar
*	geronimo-j2ee-management_1.0_spec-1.0.jar
*	geronimo-jms_1.1_spec-1.0.jar
*	 incubator-activemq-4.0.2.jar

Please let me know, a work around for this . 
thanks,
suchitha.
 

  </pre>
</blockquote>
<br>
</body>
</html>

Mime
View raw message