activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From neon18 <neo...@nngo.net>
Subject Async Writer Thread Shutdown error adding a message on 5.15.2 broker
Date Fri, 05 Jan 2018 16:03:00 GMT
We recently upgraded to ActiveMQ server 5.15.2 from 5.12.2 and when putting
some messages onto a Queue, we get the following error

ERROR | Caught an Exception adding a message: ActiveMQObjectMessage
{commandId = 2705, ...} first to FilePendingMessageCursor |
org.apache.acivemq.broker.region.cursors.FIlePendingMEssageCursor | ActiveMQ
Transport: tcp://....
java.io.IOException: Async Writer Thread Shutdown
  at
org.apache.activemq.store.kahadb.disk.journal.DataFileAppender.enqueue(DataFileAppender.java:164)[activemq-kahadb-store-5.15.2.jar:5.15.2]
  at
org.apache.activemq.store.kahadb.disk.journal.DataFileAppender.storeItem(DataFileAppender.java:129)[activemq-kahadb-store-5.15.2.jar:5.15.2]
  at
org.apache.activemq.store.kahadb.disk.journal.Journal.write(Journal.java:958)[activemq-kahadb-store-5.15.2.jar:5.15.2]
  at
org.apache.activemq.store.kahadb.plist.PListStoreImpl.write(PListStoreImpl.java:444)[activemq-kahadb-store-5.15.2.jar:5.15.2]
  at
org.apache.activemq.store.kahadb.plist.PListImpl.write(PListImpl.java:105)[activemq-kahadb-store-5.15.2.jar:5.15.2]
  at
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.tryAddMessageLast(FilePendingMessageCursor.java:237)[activemq-broker-5.15.2.jar:5.15.2]
  at
org.apache.activemq.broker.region.cursors.StoreQueueCursor.tryAddMessageLast(StoreQueueCursor.java:100)[activemq-broker-5.15.2.jar:5.15.2]
  at
org.apache.activemq.broker.region.Queue.tryCursorAdd(Queue.java:1868)[activemq-broker-5.15.2.jar:5.15.2]
...

When we were using ActiveMQ 5.12.2 server we did not have this issue.

Any ideas on why this is happening (there are lots of the above errors in
the activemq.log) and how to resolve it?

Eventually, the 5.15.2 server logs a WARN | Transport Connection to
tcp://... failed java.io.Exception: Unexpected error occurred:
java.lang.OutOfMemoryError: Java heap space |
org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ
Transport: tcp:///...

The client that submits to the queue is still using the
activemq-client-5.12.2.jar (do we need to also upgrade the client to use the
matching version as the server?

Regards,

Neon






--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Mime
View raw message