'AMQ222244: Unable to check if message expired artemis 2.17.0

We are using ActiveMQ Artemis 2.17.0, and I observed that producer are getting stuck after a while. Producers are still using the ActiveMQ 5.16.3 client library.

The lock observed on client side:

"Thread-13422" #14272 prio=5 os_prio=0 tid=0x000055a74d20a000 nid=0x7a46 waiting on condition [0x00007fa5523dd000]
 java.lang.Thread.State: WAITING (parking)
    at sun.misc.Unsafe.park(Native Method)
    - parking to wait for  <0x00000006b2a00338> (at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
    at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
    at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
    at java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403)
    at org.apache.activemq.transport.FutureResponse.getResult(FutureResponse.java:48)
    at org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:87)
    at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1388)
    at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1428)
    at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1323)
    at org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1974)
    - locked <0x00000006b2a00488> (a java.lang.Object)
    at org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:288)
    at org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:223)
    at org.apache.activemq.jms.pool.PooledProducer.send(PooledProducer.java:95)
    - locked <0x00000006b2a00508> (a org.apache.activemq.ActiveMQMessageProducer)

On the server side I saw this exception:

AMQ222244: Unable to check if message expired: org.apache.activemq.artemis.core.paging.cursor.NonExistentPage: Invalid messageNumber passed = PagePositionImpl [pageNr=1224, messageNr=1233, recordID=2178453908, fileOffset=9056626] on null
    at org.apache.activemq.artemis.core.paging.cursor.impl.PageCursorProviderImpl.getMessage(PageCursorProviderImpl.java:148)
    at org.apache.activemq.artemis.core.paging.cursor.impl.PageSubscriptionImpl.queryMessage(PageSubscriptionImpl.java:634)
    at org.apache.activemq.artemis.core.paging.cursor.PagedReferenceImpl.getPagedMessage(PagedReferenceImpl.java:132)
    at org.apache.activemq.artemis.core.paging.cursor.PagedReferenceImpl.getMessage(PagedReferenceImpl.java:99)
    at org.apache.activemq.artemis.core.server.impl.QueueImpl.checkExpired(QueueImpl.java:3815)
    at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:2981)
    at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$2400(QueueImpl.java:126)
    at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:4163)
    at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42)
    at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31)
    at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:65)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118)

What is the root cause of that issue? How can we prevent it?

activemq-artemis


Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution Source

Related Questions