activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dejan Bosanac <de...@nighttale.net>
Subject Re: Stomp EOFException logged
Date Wed, 08 Jun 2011 07:44:00 GMT
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.green@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 <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