activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dejan Bosanac <de...@nighttale.net>
Subject Re: ActiveMQ log question
Date Fri, 26 Aug 2011 08:07:41 GMT
This message means that client closed the socket unexpectedly. It's not an
error on broker side.


Regards
-- 
Dejan Bosanac - http://twitter.com/dejanb
-----------------
The experts in open source integration and messaging - http://fusesource.com
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://www.nighttale.net


On Thu, Aug 25, 2011 at 10:41 PM, Rishi Sood <mohan_sood@yahoo.com> wrote:

> Hello,
>
> Sorry for the repost I don't think I was subscribed properly with my
> previous attempt.
>
> I have a question regarding some messages that are appearing in the
> activemq.log and what they actually mean.  I've recently setup a server
> running AMQ5.5.0.  I've got stomp+nio setup as the transport connector.
>  And
> I'm using Hiram's benchmark tool to put it through it's paces.  I turned on
> the DEBUG log to get more information, but I can't figure out why I'm
> getting the EOFException or the IOException.  It looks like things recover
> just fine.  But I can't shake the feeling that something is happening that
> shouldn't be happening.  Or that maybe messages are being dropped.  Any
> ideas on configurations that I could tweak to handle this?  Am I even
> interpreting the log correctly?
>
> Thanks
>
> Rishi
>
>
> 2011-08-24 14:55:37,603 | DEBUG | Transport failed: java.io.EOFException |
> org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ NIO
> Worker
> java.io.EOFException
>        at
>
> org.apache.activemq.transport.stomp.StompNIOTransport.serviceRead(StompNIOTransport.java:106)
>        at
>
> org.apache.activemq.transport.stomp.StompNIOTransport.access$000(StompNIOTransport.java:51)
>        at
>
> org.apache.activemq.transport.stomp.StompNIOTransport$1.onSelect(StompNIOTransport.java:80)
>        at
>
> org.apache.activemq.transport.nio.SelectorSelection.onSelect(SelectorSelection.java:94)
>        at
>
> org.apache.activemq.transport.nio.SelectorWorker$1.run(SelectorWorker.java:119)
>        at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
>        at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
>        at java.lang.Thread.run(Thread.java:619)
> 2011-08-24 14:55:37,603 | DEBUG | Connection Stopped: null |
> org.apache.activemq.broker.TransportConnection | ActiveMQ Task-31
> 2011-08-24 14:55:37,603 | DEBUG | Transport failed: java.io.IOException:
> Connection reset by peer |
> org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ NIO
> Worker
> java.io.IOException: Connection reset by peer
>        at sun.nio.ch.FileDispatcher.read0(Native Method)
>        at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:21)
>        at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:233)
>        at sun.nio.ch.IOUtil.read(IOUtil.java:206)
>        at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:236)
>        at
>
> org.apache.activemq.transport.stomp.StompNIOTransport.serviceRead(StompNIOTransport.java:103)
>        at
>
> org.apache.activemq.transport.stomp.StompNIOTransport.access$000(StompNIOTransport.java:51)
>        at
>
> org.apache.activemq.transport.stomp.StompNIOTransport$1.onSelect(StompNIOTransport.java:80)
>        at
>
> org.apache.activemq.transport.nio.SelectorSelection.onSelect(SelectorSelection.java:94)
>        at
>
> org.apache.activemq.transport.nio.SelectorWorker$1.run(SelectorWorker.java:119)
>        at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
>        at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
>        at java.lang.Thread.run(Thread.java:619)
> 2011-08-24 14:55:37,617 | DEBUG | Stopping connection:
> /XXX.XXX.XXX.XXX:39680 | org.apache.activemq.broker.TransportConnection |
> ActiveMQ Task-48
> 2011-08-24 14:55:37,617 | DEBUG | Stopping connection:
> /XXX.XXX.XXX.XXX:39686 | org.apache.activemq.broker.TransportConnection |
> ActiveMQ Task-41
> 2011-08-24 14:55:37,617 | DEBUG | Stopping transport
> tcp:///XXX.XXX.XXX.XXX:39686 |
> org.apache.activemq.transport.tcp.TcpTransport | ActiveMQ Task-41
> 2011-08-24 14:55:37,617 | DEBUG | Stopping connection:
> /XXX.XXX.XXX.XXX:39689 | org.apache.activemq.broker.TransportConnection |
> ActiveMQ Task-44
> 2011-08-24 14:55:37,617 | DEBUG | Stopping connection:
> /XXX.XXX.XXX.XXX:39678 | org.apache.activemq.broker.TransportConnection |
> ActiveMQ Task-31
> 2011-08-24 14:55:37,617 | DEBUG | Stopped transport: null |
> org.apache.activemq.broker.TransportConnection | ActiveMQ Task-41
> 2011-08-24 14:55:37,617 | DEBUG | Cleaning up connection resources: null |
> org.apache.activemq.broker.TransportConnection | ActiveMQ Task-33
> 2011-08-24 14:55:37,617 | DEBUG | remove connection id:
> ID:activemq-be1-46594-1314222843144-4:45 |
> org.apache.activemq.broker.TransportConnection | ActiveMQ Task-33
> 2011-08-24 14:55:37,618 | DEBUG | Setting up new connection id:
> ID:activemq-be1-46594-1314222843144-4:56, address: /XXX.XXX.XXX.XXX:48127 |
> org.apache.activemq.broker.TransportConnection | ActiveMQ NIO Worker
> 2011-08-24 14:55:37,618 | DEBUG | Stopping transport
> tcp:///XXX.XXX.XXX.XXX:39678 |
> org.apache.activemq.transport.tcp.TcpTransport | ActiveMQ Task-31
> 2011-08-24 14:55:37,618 | DEBUG | Stopped transport: null |
> org.apache.activemq.broker.TransportConnection | ActiveMQ Task-31
> 2011-08-24 14:55:37,618 | DEBUG | Cleaning up connection resources: null |
> org.apache.activemq.broker.TransportConnection | ActiveMQ Task-41
> 2011-08-24 14:55:37,618 | DEBUG | Stopping transport
> tcp:///XXX.XXX.XXX.XXX:39680 |
> org.apache.activemq.transport.tcp.TcpTransport | ActiveMQ Task-48
> 2011-08-24 14:55:37,603 | DEBUG | Transport failed: java.io.IOException:
> Connection reset by peer |
> org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ NIO
> Worker
> java.io.IOException: Connection reset by peer
>        at sun.nio.ch.FileDispatcher.read0(Native Method)
>        at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:21)
>        at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:233)
>        at sun.nio.ch.IOUtil.read(IOUtil.java:206)
>        at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:236)
>        at
>
> org.apache.activemq.transport.stomp.StompNIOTransport.serviceRead(StompNIOTransport.java:103)
>        at
>
> org.apache.activemq.transport.stomp.StompNIOTransport.access$000(StompNIOTransport.java:51)
>        at
>
> org.apache.activemq.transport.stomp.StompNIOTransport$1.onSelect(StompNIOTransport.java:80)
>        at
>
> org.apache.activemq.transport.nio.SelectorSelection.onSelect(SelectorSelection.java:94)
>        at
>
> org.apache.activemq.transport.nio.SelectorWorker$1.run(SelectorWorker.java:119)
>        at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
>        at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
>        at java.lang.Thread.run(Thread.java:619)
> 2011-08-24 14:55:37,619 | DEBUG | Stopped transport: null |
> org.apache.activemq.broker.TransportConnection | ActiveMQ Task-48
> 2011-08-24 14:55:37,619 | DEBUG | Setting up new connection id:
> ID:activemq-be1-46594-1314222843144-4:58, address: /XXX.XXX.XXX.XXX:48125 |
> org.apache.activemq.broker.TransportConnection | ActiveMQ NIO Worker
> 2011-08-24 14:55:37,619 | DEBUG | Setting up new connection id:
> ID:activemq-be1-46594-1314222843144-4:54, address: /XXX.XXX.XXX.XXX:48128 |
> org.apache.activemq.broker.TransportConnection | ActiveMQ NIO Worker
> 2011-08-24 14:55:37,620 | DEBUG | Stopping connection:
> /XXX.XXX.XXX.XXX:39676 | org.apache.activemq.broker.TransportConnection |
> ActiveMQ Task-46
> 2011-08-24 14:55:37,620 | DEBUG | Stopping transport
> tcp:///XXX.XXX.XXX.XXX:39676 |
> org.apache.activemq.transport.tcp.TcpTransport | ActiveMQ Task-46
> 2011-08-24 14:55:37,620 | DEBUG | Stopped transport: null |
> org.apache.activemq.broker.TransportConnection | ActiveMQ Task-46
> 2011-08-24 14:55:37,620 | DEBUG | Cleaning up connection resources: null |
> org.apache.activemq.broker.TransportConnection | ActiveMQ Task-46
> 2011-08-24 14:55:37,620 | DEBUG | remove connection id:
> ID:activemq-be1-46594-1314222843144-4:29 |
> org.apache.activemq.broker.TransportConnection | ActiveMQ Task-46
> 2011-08-24 14:55:37,619 | DEBUG | Cleaning up connection resources: null |
> org.apache.activemq.broker.TransportConnection | ActiveMQ Task-31
> 2011-08-24 14:55:37,618 | DEBUG | remove connection id:
> ID:activemq-be1-46594-1314222843144-4:38 |
> org.apache.activemq.broker.TransportConnection | ActiveMQ Task-41
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-log-question-tp3769350p3769350.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message