You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by James Green <ja...@gmail.com> on 2011/06/07 10:51:58 UTC
Stomp EOFException logged
Got a Stomp client that just reported "Server not responding". Logs from
AMQ:
2011-06-07 09:45:15,087 | DEBUG | Setting up new connection id:
ID:ubuntu-33097-1307336686696-
5:54, address: /127.0.0.1:36529 |
org.apache.activemq.broker.TransportConnection | ActiveMQ Tr
ansport: tcp:///127.0.0.1:36529
2011-06-07 09:45:15,307 | DEBUG | Setting up new connection id:
ID:ubuntu-33097-1307336686696-
5:55, address: /127.0.0.1:36530 |
org.apache.activemq.broker.TransportConnection | ActiveMQ Tr
ansport: tcp:///127.0.0.1:36530
2011-06-07 09:45:20,275 | DEBUG | Checkpoint started. |
org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
Checkpoint Worker
2011-06-07 09:45:20,287 | TRACE | Last update: 109:26476880, full gc
candidates set: [87, 88, 91, 92, 104, 105, 106, 109] |
org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
Checkpoint Worker
2011-06-07 09:45:20,287 | TRACE | gc candidates after first tx:109:26476880,
[87, 88, 91, 92, 104, 105, 106] |
org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
Checkpoint Worker
2011-06-07 09:45:20,287 | TRACE | gc candidates after
dest:0:Outbound.Account.200000, [87, 88, 91, 92, 104, 105, 106] |
org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
Checkpoint Worker
2011-06-07 09:45:20,287 | TRACE | gc candidates after
dest:1:Server.Requests, [] |
org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
Checkpoint Worker
2011-06-07 09:45:20,287 | TRACE | gc candidates: [] |
org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
Checkpoint Worker
2011-06-07 09:45:20,287 | DEBUG | Checkpoint done. |
org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
Checkpoint Worker
2011-06-07 09:45:20,340 | DEBUG | Setting up new connection id:
ID:ubuntu-33097-1307336686696-5:56, address: /127.0.0.1:36531 |
org.apache.activemq.broker.TransportConnection | ActiveMQ Transport: tcp:///
127.0.0.1:36531
2011-06-07 09:45:20,340 | DEBUG | Transport failed: java.io.EOFException |
org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ
Transport: tcp:///127.0.0.1:36531
java.io.EOFException
at java.io.DataInputStream.readByte(DataInputStream.java:250)
at
org.apache.activemq.transport.stomp.StompWireFormat.readLine(StompWireFormat.java:146)
at
org.apache.activemq.transport.stomp.StompWireFormat.parseAction(StompWireFormat.java:162)
at
org.apache.activemq.transport.stomp.StompWireFormat.unmarshal(StompWireFormat.java:92)
at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:227)
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
at java.lang.Thread.run(Thread.java:619)
2011-06-07 09:45:20,343 | DEBUG | Stopping connection: /127.0.0.1:36531 |
org.apache.activemq.broker.TransportConnection | StopAsync:/127.0.0.1:36531
-16344
2011-06-07 09:45:20,343 | DEBUG | Stopping transport
tcp:///127.0.0.1:36531| org.apache.activemq.transport.tcp.TcpTransport
|
StopAsync:/127.0.0.1:36531-16344
2011-06-07 09:45:20,343 | DEBUG | Stopped transport: /127.0.0.1:36531 |
org.apache.activemq.broker.TransportConnection | StopAsync:/127.0.0.1:36531
-16344
2011-06-07 09:45:20,343 | DEBUG | Cleaning up connection resources: /
127.0.0.1:36531 | org.apache.activemq.broker.TransportConnection |
StopAsync:/127.0.0.1:36531-16344
2011-06-07 09:45:20,343 | DEBUG | remove connection id:
ID:ubuntu-33097-1307336686696-5:56 |
org.apache.activemq.broker.TransportConnection | StopAsync:/127.0.0.1:36531
-16344
2011-06-07 09:45:20,343 | DEBUG | Connection Stopped: /127.0.0.1:36531 |
org.apache.activemq.broker.TransportConnection | StopAsync:/127.0.0.1:36531
-16344
2011-06-07 09:45:20,365 | DEBUG |
Main:memory:topic://Server.Requests:memory: usage change from: 378% of
available memory, to: 400% of available memory |
org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///127.0.0.1:36529
2011-06-07 09:45:20,366 | DEBUG | Main:memory: usage change from: 59% of
available memory, to: 62% of available memory |
org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///127.0.0.1:36529
2011-06-07 09:45:20,369 | DEBUG | remove connection id:
ID:ubuntu-33097-1307336686696-5:55 |
org.apache.activemq.broker.TransportConnection | ActiveMQ Transport: tcp:///
127.0.0.1:36530
2011-06-07 09:45:20,370 | DEBUG | remove connection id:
ID:ubuntu-33097-1307336686696-5:54 |
org.apache.activemq.broker.TransportConnection | ActiveMQ Transport: tcp:///
127.0.0.1:36529
2011-06-07 09:45:20,370 | DEBUG | bridging (ubuntu -> blofeld, consumer:
ID:ubuntu-33097-1307336686696-4:2:1:8, destination topic://Server.Requests,
brokerPath: [ID:ubuntu-33097-1307336686696-0:1], message:
ActiveMQTextMessage {commandId = 3, responseRequired = false, messageId =
ID:ubuntu-33097-1307336686696-5:54:-1:1:1, originalDestination = null,
originalTransactionId = null, producerId =
ID:ubuntu-33097-1307336686696-4:1:1:1, destination =
topic://Server.Requests, transactionId = null, expiration = 0, timestamp =
1307436315307, arrival = 0, brokerInTime = 1307436315307, brokerOutTime =
1307436320366, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@1897eb0, marshalledProperties = null,
dataStructure = null, redeliveryCounter = 0, size = 2271164, properties =
null, readOnlyProperties = true, readOnlyBody = true, droppable = false,
text = <?xml version="1.0"?>
<request><class id="cla...></request>
} | org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Connection Dispatcher: vm://ubuntu#2
Can anyone say if this is already in JIRA? If not I can add it.
Thanks,
James
Re: Stomp EOFException logged
Posted by Dejan Bosanac <de...@nighttale.net>.
There is no such timeout on the 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 Tue, Jun 7, 2011 at 3:14 PM, James Green <ja...@gmail.com>wrote:
> Good question. Only thing I can say is that it's a reasonably large XML
> packet being posted. I will try to find the size of it in a debug session.
>
> Is there a timeout period during a send perhaps that should be tweaked?
>
> On 7 June 2011 11:59, Dejan Bosanac <de...@nighttale.net> wrote:
>
> > Hi James,
> >
> > this exception just means that the client closed the connection to the
> > broker unexpectedly. It would be helpful if you could find a way to
> > reproduce what you're seeing.
> >
> > 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 Tue, Jun 7, 2011 at 10:51 AM, James Green <james.mk.green@gmail.com
> > >wrote:
> >
> > > Got a Stomp client that just reported "Server not responding". Logs
> from
> > > AMQ:
> > >
> > > 2011-06-07 09:45:15,087 | DEBUG | Setting up new connection id:
> > > ID:ubuntu-33097-1307336686696-
> > > 5:54, address: /127.0.0.1:36529 |
> > > org.apache.activemq.broker.TransportConnection | ActiveMQ Tr
> > > ansport: tcp:///127.0.0.1:36529
> > > 2011-06-07 09:45:15,307 | DEBUG | Setting up new connection id:
> > > ID:ubuntu-33097-1307336686696-
> > > 5:55, address: /127.0.0.1:36530 |
> > > org.apache.activemq.broker.TransportConnection | ActiveMQ Tr
> > > ansport: tcp:///127.0.0.1:36530
> > > 2011-06-07 09:45:20,275 | DEBUG | Checkpoint started. |
> > > org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> > > Checkpoint Worker
> > > 2011-06-07 09:45:20,287 | TRACE | Last update: 109:26476880, full gc
> > > candidates set: [87, 88, 91, 92, 104, 105, 106, 109] |
> > > org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> > > Checkpoint Worker
> > > 2011-06-07 09:45:20,287 | TRACE | gc candidates after first
> > > tx:109:26476880,
> > > [87, 88, 91, 92, 104, 105, 106] |
> > > org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> > > Checkpoint Worker
> > > 2011-06-07 09:45:20,287 | TRACE | gc candidates after
> > > dest:0:Outbound.Account.200000, [87, 88, 91, 92, 104, 105, 106] |
> > > org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> > > Checkpoint Worker
> > > 2011-06-07 09:45:20,287 | TRACE | gc candidates after
> > > dest:1:Server.Requests, [] |
> > > org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> > > Checkpoint Worker
> > > 2011-06-07 09:45:20,287 | TRACE | gc candidates: [] |
> > > org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> > > Checkpoint Worker
> > > 2011-06-07 09:45:20,287 | DEBUG | Checkpoint done. |
> > > org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> > > Checkpoint Worker
> > > 2011-06-07 09:45:20,340 | DEBUG | Setting up new connection id:
> > > ID:ubuntu-33097-1307336686696-5:56, address: /127.0.0.1:36531 |
> > > org.apache.activemq.broker.TransportConnection | ActiveMQ Transport:
> > > tcp:///
> > > 127.0.0.1:36531
> > > 2011-06-07 09:45:20,340 | DEBUG | Transport failed:
> java.io.EOFException
> > |
> > > org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ
> > > Transport: tcp:///127.0.0.1:36531
> > > java.io.EOFException
> > > at java.io.DataInputStream.readByte(DataInputStream.java:250)
> > > at
> > >
> > >
> >
> org.apache.activemq.transport.stomp.StompWireFormat.readLine(StompWireFormat.java:146)
> > > at
> > >
> > >
> >
> org.apache.activemq.transport.stomp.StompWireFormat.parseAction(StompWireFormat.java:162)
> > > at
> > >
> > >
> >
> org.apache.activemq.transport.stomp.StompWireFormat.unmarshal(StompWireFormat.java:92)
> > > at
> > >
> > >
> >
> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:227)
> > > at
> > >
> >
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219)
> > > at
> > >
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
> > > at java.lang.Thread.run(Thread.java:619)
> > > 2011-06-07 09:45:20,343 | DEBUG | Stopping connection: /127.0.0.1:36531
> |
> > > org.apache.activemq.broker.TransportConnection | StopAsync:/
> > > 127.0.0.1:36531
> > > -16344
> > > 2011-06-07 09:45:20,343 | DEBUG | Stopping transport
> > > tcp:///127.0.0.1:36531| org.apache.activemq.transport.tcp.TcpTransport
> > > |
> > > StopAsync:/127.0.0.1:36531-16344
> > > 2011-06-07 09:45:20,343 | DEBUG | Stopped transport: /127.0.0.1:36531|
> > > org.apache.activemq.broker.TransportConnection | StopAsync:/
> > > 127.0.0.1:36531
> > > -16344
> > > 2011-06-07 09:45:20,343 | DEBUG | Cleaning up connection resources: /
> > > 127.0.0.1:36531 | org.apache.activemq.broker.TransportConnection |
> > > StopAsync:/127.0.0.1:36531-16344
> > > 2011-06-07 09:45:20,343 | DEBUG | remove connection id:
> > > ID:ubuntu-33097-1307336686696-5:56 |
> > > org.apache.activemq.broker.TransportConnection | StopAsync:/
> > > 127.0.0.1:36531
> > > -16344
> > > 2011-06-07 09:45:20,343 | DEBUG | Connection Stopped: /127.0.0.1:36531|
> > > org.apache.activemq.broker.TransportConnection | StopAsync:/
> > > 127.0.0.1:36531
> > > -16344
> > > 2011-06-07 09:45:20,365 | DEBUG |
> > > Main:memory:topic://Server.Requests:memory: usage change from: 378% of
> > > available memory, to: 400% of available memory |
> > > org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///
> > > 127.0.0.1:36529
> > > 2011-06-07 09:45:20,366 | DEBUG | Main:memory: usage change from: 59%
> of
> > > available memory, to: 62% of available memory |
> > > org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///
> > > 127.0.0.1:36529
> > > 2011-06-07 09:45:20,369 | DEBUG | remove connection id:
> > > ID:ubuntu-33097-1307336686696-5:55 |
> > > org.apache.activemq.broker.TransportConnection | ActiveMQ Transport:
> > > tcp:///
> > > 127.0.0.1:36530
> > > 2011-06-07 09:45:20,370 | DEBUG | remove connection id:
> > > ID:ubuntu-33097-1307336686696-5:54 |
> > > org.apache.activemq.broker.TransportConnection | ActiveMQ Transport:
> > > tcp:///
> > > 127.0.0.1:36529
> > > 2011-06-07 09:45:20,370 | DEBUG | bridging (ubuntu -> blofeld,
> consumer:
> > > ID:ubuntu-33097-1307336686696-4:2:1:8, destination
> > topic://Server.Requests,
> > > brokerPath: [ID:ubuntu-33097-1307336686696-0:1], message:
> > > ActiveMQTextMessage {commandId = 3, responseRequired = false, messageId
> =
> > > ID:ubuntu-33097-1307336686696-5:54:-1:1:1, originalDestination = null,
> > > originalTransactionId = null, producerId =
> > > ID:ubuntu-33097-1307336686696-4:1:1:1, destination =
> > > topic://Server.Requests, transactionId = null, expiration = 0,
> timestamp
> > =
> > > 1307436315307, arrival = 0, brokerInTime = 1307436315307, brokerOutTime
> =
> > > 1307436320366, correlationId = null, replyTo = null, persistent = true,
> > > type
> > > = null, priority = 4, groupID = null, groupSequence = 0,
> targetConsumerId
> > =
> > > null, compressed = false, userID = null, content =
> > > org.apache.activemq.util.ByteSequence@1897eb0, marshalledProperties =
> > > null,
> > > dataStructure = null, redeliveryCounter = 0, size = 2271164, properties
> =
> > > null, readOnlyProperties = true, readOnlyBody = true, droppable =
> false,
> > > text = <?xml version="1.0"?>
> > > <request><class id="cla...></request>
> > > } | org.apache.activemq.network.DemandForwardingBridgeSupport |
> ActiveMQ
> > > Connection Dispatcher: vm://ubuntu#2
> > >
> > > Can anyone say if this is already in JIRA? If not I can add it.
> > >
> > > Thanks,
> > >
> > > James
> > >
> >
>
Re: Stomp EOFException logged
Posted by James Green <ja...@gmail.com>.
Good question. Only thing I can say is that it's a reasonably large XML
packet being posted. I will try to find the size of it in a debug session.
Is there a timeout period during a send perhaps that should be tweaked?
On 7 June 2011 11:59, Dejan Bosanac <de...@nighttale.net> wrote:
> Hi James,
>
> this exception just means that the client closed the connection to the
> broker unexpectedly. It would be helpful if you could find a way to
> reproduce what you're seeing.
>
> 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 Tue, Jun 7, 2011 at 10:51 AM, James Green <james.mk.green@gmail.com
> >wrote:
>
> > Got a Stomp client that just reported "Server not responding". Logs from
> > AMQ:
> >
> > 2011-06-07 09:45:15,087 | DEBUG | Setting up new connection id:
> > ID:ubuntu-33097-1307336686696-
> > 5:54, address: /127.0.0.1:36529 |
> > org.apache.activemq.broker.TransportConnection | ActiveMQ Tr
> > ansport: tcp:///127.0.0.1:36529
> > 2011-06-07 09:45:15,307 | DEBUG | Setting up new connection id:
> > ID:ubuntu-33097-1307336686696-
> > 5:55, address: /127.0.0.1:36530 |
> > org.apache.activemq.broker.TransportConnection | ActiveMQ Tr
> > ansport: tcp:///127.0.0.1:36530
> > 2011-06-07 09:45:20,275 | DEBUG | Checkpoint started. |
> > org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> > Checkpoint Worker
> > 2011-06-07 09:45:20,287 | TRACE | Last update: 109:26476880, full gc
> > candidates set: [87, 88, 91, 92, 104, 105, 106, 109] |
> > org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> > Checkpoint Worker
> > 2011-06-07 09:45:20,287 | TRACE | gc candidates after first
> > tx:109:26476880,
> > [87, 88, 91, 92, 104, 105, 106] |
> > org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> > Checkpoint Worker
> > 2011-06-07 09:45:20,287 | TRACE | gc candidates after
> > dest:0:Outbound.Account.200000, [87, 88, 91, 92, 104, 105, 106] |
> > org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> > Checkpoint Worker
> > 2011-06-07 09:45:20,287 | TRACE | gc candidates after
> > dest:1:Server.Requests, [] |
> > org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> > Checkpoint Worker
> > 2011-06-07 09:45:20,287 | TRACE | gc candidates: [] |
> > org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> > Checkpoint Worker
> > 2011-06-07 09:45:20,287 | DEBUG | Checkpoint done. |
> > org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> > Checkpoint Worker
> > 2011-06-07 09:45:20,340 | DEBUG | Setting up new connection id:
> > ID:ubuntu-33097-1307336686696-5:56, address: /127.0.0.1:36531 |
> > org.apache.activemq.broker.TransportConnection | ActiveMQ Transport:
> > tcp:///
> > 127.0.0.1:36531
> > 2011-06-07 09:45:20,340 | DEBUG | Transport failed: java.io.EOFException
> |
> > org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ
> > Transport: tcp:///127.0.0.1:36531
> > java.io.EOFException
> > at java.io.DataInputStream.readByte(DataInputStream.java:250)
> > at
> >
> >
> org.apache.activemq.transport.stomp.StompWireFormat.readLine(StompWireFormat.java:146)
> > at
> >
> >
> org.apache.activemq.transport.stomp.StompWireFormat.parseAction(StompWireFormat.java:162)
> > at
> >
> >
> org.apache.activemq.transport.stomp.StompWireFormat.unmarshal(StompWireFormat.java:92)
> > at
> >
> >
> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:227)
> > at
> >
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219)
> > at
> > org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
> > at java.lang.Thread.run(Thread.java:619)
> > 2011-06-07 09:45:20,343 | DEBUG | Stopping connection: /127.0.0.1:36531|
> > org.apache.activemq.broker.TransportConnection | StopAsync:/
> > 127.0.0.1:36531
> > -16344
> > 2011-06-07 09:45:20,343 | DEBUG | Stopping transport
> > tcp:///127.0.0.1:36531| org.apache.activemq.transport.tcp.TcpTransport
> > |
> > StopAsync:/127.0.0.1:36531-16344
> > 2011-06-07 09:45:20,343 | DEBUG | Stopped transport: /127.0.0.1:36531 |
> > org.apache.activemq.broker.TransportConnection | StopAsync:/
> > 127.0.0.1:36531
> > -16344
> > 2011-06-07 09:45:20,343 | DEBUG | Cleaning up connection resources: /
> > 127.0.0.1:36531 | org.apache.activemq.broker.TransportConnection |
> > StopAsync:/127.0.0.1:36531-16344
> > 2011-06-07 09:45:20,343 | DEBUG | remove connection id:
> > ID:ubuntu-33097-1307336686696-5:56 |
> > org.apache.activemq.broker.TransportConnection | StopAsync:/
> > 127.0.0.1:36531
> > -16344
> > 2011-06-07 09:45:20,343 | DEBUG | Connection Stopped: /127.0.0.1:36531 |
> > org.apache.activemq.broker.TransportConnection | StopAsync:/
> > 127.0.0.1:36531
> > -16344
> > 2011-06-07 09:45:20,365 | DEBUG |
> > Main:memory:topic://Server.Requests:memory: usage change from: 378% of
> > available memory, to: 400% of available memory |
> > org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///
> > 127.0.0.1:36529
> > 2011-06-07 09:45:20,366 | DEBUG | Main:memory: usage change from: 59% of
> > available memory, to: 62% of available memory |
> > org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///
> > 127.0.0.1:36529
> > 2011-06-07 09:45:20,369 | DEBUG | remove connection id:
> > ID:ubuntu-33097-1307336686696-5:55 |
> > org.apache.activemq.broker.TransportConnection | ActiveMQ Transport:
> > tcp:///
> > 127.0.0.1:36530
> > 2011-06-07 09:45:20,370 | DEBUG | remove connection id:
> > ID:ubuntu-33097-1307336686696-5:54 |
> > org.apache.activemq.broker.TransportConnection | ActiveMQ Transport:
> > tcp:///
> > 127.0.0.1:36529
> > 2011-06-07 09:45:20,370 | DEBUG | bridging (ubuntu -> blofeld, consumer:
> > ID:ubuntu-33097-1307336686696-4:2:1:8, destination
> topic://Server.Requests,
> > brokerPath: [ID:ubuntu-33097-1307336686696-0:1], message:
> > ActiveMQTextMessage {commandId = 3, responseRequired = false, messageId =
> > ID:ubuntu-33097-1307336686696-5:54:-1:1:1, originalDestination = null,
> > originalTransactionId = null, producerId =
> > ID:ubuntu-33097-1307336686696-4:1:1:1, destination =
> > topic://Server.Requests, transactionId = null, expiration = 0, timestamp
> =
> > 1307436315307, arrival = 0, brokerInTime = 1307436315307, brokerOutTime =
> > 1307436320366, correlationId = null, replyTo = null, persistent = true,
> > type
> > = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId
> =
> > null, compressed = false, userID = null, content =
> > org.apache.activemq.util.ByteSequence@1897eb0, marshalledProperties =
> > null,
> > dataStructure = null, redeliveryCounter = 0, size = 2271164, properties =
> > null, readOnlyProperties = true, readOnlyBody = true, droppable = false,
> > text = <?xml version="1.0"?>
> > <request><class id="cla...></request>
> > } | org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
> > Connection Dispatcher: vm://ubuntu#2
> >
> > Can anyone say if this is already in JIRA? If not I can add it.
> >
> > Thanks,
> >
> > James
> >
>
Re: Stomp EOFException logged
Posted by Dejan Bosanac <de...@nighttale.net>.
Hi James,
this exception just means that the client closed the connection to the
broker unexpectedly. It would be helpful if you could find a way to
reproduce what you're seeing.
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 Tue, Jun 7, 2011 at 10:51 AM, James Green <ja...@gmail.com>wrote:
> Got a Stomp client that just reported "Server not responding". Logs from
> AMQ:
>
> 2011-06-07 09:45:15,087 | DEBUG | Setting up new connection id:
> ID:ubuntu-33097-1307336686696-
> 5:54, address: /127.0.0.1:36529 |
> org.apache.activemq.broker.TransportConnection | ActiveMQ Tr
> ansport: tcp:///127.0.0.1:36529
> 2011-06-07 09:45:15,307 | DEBUG | Setting up new connection id:
> ID:ubuntu-33097-1307336686696-
> 5:55, address: /127.0.0.1:36530 |
> org.apache.activemq.broker.TransportConnection | ActiveMQ Tr
> ansport: tcp:///127.0.0.1:36530
> 2011-06-07 09:45:20,275 | DEBUG | Checkpoint started. |
> org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> Checkpoint Worker
> 2011-06-07 09:45:20,287 | TRACE | Last update: 109:26476880, full gc
> candidates set: [87, 88, 91, 92, 104, 105, 106, 109] |
> org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> Checkpoint Worker
> 2011-06-07 09:45:20,287 | TRACE | gc candidates after first
> tx:109:26476880,
> [87, 88, 91, 92, 104, 105, 106] |
> org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> Checkpoint Worker
> 2011-06-07 09:45:20,287 | TRACE | gc candidates after
> dest:0:Outbound.Account.200000, [87, 88, 91, 92, 104, 105, 106] |
> org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> Checkpoint Worker
> 2011-06-07 09:45:20,287 | TRACE | gc candidates after
> dest:1:Server.Requests, [] |
> org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> Checkpoint Worker
> 2011-06-07 09:45:20,287 | TRACE | gc candidates: [] |
> org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> Checkpoint Worker
> 2011-06-07 09:45:20,287 | DEBUG | Checkpoint done. |
> org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> Checkpoint Worker
> 2011-06-07 09:45:20,340 | DEBUG | Setting up new connection id:
> ID:ubuntu-33097-1307336686696-5:56, address: /127.0.0.1:36531 |
> org.apache.activemq.broker.TransportConnection | ActiveMQ Transport:
> tcp:///
> 127.0.0.1:36531
> 2011-06-07 09:45:20,340 | DEBUG | Transport failed: java.io.EOFException |
> org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ
> Transport: tcp:///127.0.0.1:36531
> java.io.EOFException
> at java.io.DataInputStream.readByte(DataInputStream.java:250)
> at
>
> org.apache.activemq.transport.stomp.StompWireFormat.readLine(StompWireFormat.java:146)
> at
>
> org.apache.activemq.transport.stomp.StompWireFormat.parseAction(StompWireFormat.java:162)
> at
>
> org.apache.activemq.transport.stomp.StompWireFormat.unmarshal(StompWireFormat.java:92)
> at
>
> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:227)
> at
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219)
> at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
> at java.lang.Thread.run(Thread.java:619)
> 2011-06-07 09:45:20,343 | DEBUG | Stopping connection: /127.0.0.1:36531 |
> org.apache.activemq.broker.TransportConnection | StopAsync:/
> 127.0.0.1:36531
> -16344
> 2011-06-07 09:45:20,343 | DEBUG | Stopping transport
> tcp:///127.0.0.1:36531| org.apache.activemq.transport.tcp.TcpTransport
> |
> StopAsync:/127.0.0.1:36531-16344
> 2011-06-07 09:45:20,343 | DEBUG | Stopped transport: /127.0.0.1:36531 |
> org.apache.activemq.broker.TransportConnection | StopAsync:/
> 127.0.0.1:36531
> -16344
> 2011-06-07 09:45:20,343 | DEBUG | Cleaning up connection resources: /
> 127.0.0.1:36531 | org.apache.activemq.broker.TransportConnection |
> StopAsync:/127.0.0.1:36531-16344
> 2011-06-07 09:45:20,343 | DEBUG | remove connection id:
> ID:ubuntu-33097-1307336686696-5:56 |
> org.apache.activemq.broker.TransportConnection | StopAsync:/
> 127.0.0.1:36531
> -16344
> 2011-06-07 09:45:20,343 | DEBUG | Connection Stopped: /127.0.0.1:36531 |
> org.apache.activemq.broker.TransportConnection | StopAsync:/
> 127.0.0.1:36531
> -16344
> 2011-06-07 09:45:20,365 | DEBUG |
> Main:memory:topic://Server.Requests:memory: usage change from: 378% of
> available memory, to: 400% of available memory |
> org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///
> 127.0.0.1:36529
> 2011-06-07 09:45:20,366 | DEBUG | Main:memory: usage change from: 59% of
> available memory, to: 62% of available memory |
> org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///
> 127.0.0.1:36529
> 2011-06-07 09:45:20,369 | DEBUG | remove connection id:
> ID:ubuntu-33097-1307336686696-5:55 |
> org.apache.activemq.broker.TransportConnection | ActiveMQ Transport:
> tcp:///
> 127.0.0.1:36530
> 2011-06-07 09:45:20,370 | DEBUG | remove connection id:
> ID:ubuntu-33097-1307336686696-5:54 |
> org.apache.activemq.broker.TransportConnection | ActiveMQ Transport:
> tcp:///
> 127.0.0.1:36529
> 2011-06-07 09:45:20,370 | DEBUG | bridging (ubuntu -> blofeld, consumer:
> ID:ubuntu-33097-1307336686696-4:2:1:8, destination topic://Server.Requests,
> brokerPath: [ID:ubuntu-33097-1307336686696-0:1], message:
> ActiveMQTextMessage {commandId = 3, responseRequired = false, messageId =
> ID:ubuntu-33097-1307336686696-5:54:-1:1:1, originalDestination = null,
> originalTransactionId = null, producerId =
> ID:ubuntu-33097-1307336686696-4:1:1:1, destination =
> topic://Server.Requests, transactionId = null, expiration = 0, timestamp =
> 1307436315307, arrival = 0, brokerInTime = 1307436315307, brokerOutTime =
> 1307436320366, correlationId = null, replyTo = null, persistent = true,
> type
> = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
> null, compressed = false, userID = null, content =
> org.apache.activemq.util.ByteSequence@1897eb0, marshalledProperties =
> null,
> dataStructure = null, redeliveryCounter = 0, size = 2271164, properties =
> null, readOnlyProperties = true, readOnlyBody = true, droppable = false,
> text = <?xml version="1.0"?>
> <request><class id="cla...></request>
> } | org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
> Connection Dispatcher: vm://ubuntu#2
>
> Can anyone say if this is already in JIRA? If not I can add it.
>
> Thanks,
>
> James
>