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.gr...@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 >
