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