activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From James Green <james.mk.gr...@gmail.com>
Subject Re: Stomp EOFException logged
Date Tue, 07 Jun 2011 13:14:03 GMT
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 <dejan@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
> >
>

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