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