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 Tue, 07 Jun 2011 10:59:35 GMT
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