Сервер ActiveMQ Artemis выдает множество ошибок AMQ224016 в журналах после миграции на клиент Jakarta API. ⇐ JAVA

[Гость]

I have a problem using clustered instance of ActiveMQ Artemis (2 master + 2 backup), in the beginning using version 2.20.0. After services clients migration to Spring Boot 3.x, which uses artemis-jakarta-client 2.20.0 in logs I see errors on nearly every message:

2024-03-04 09:39:01,139 ERROR [org.apache.activemq.artemis.core.server] AMQ224016: Caught exception: ActiveMQIllegalStateException[errorType=ILLEGAL_STATE message=AMQ229027: Could not find reference on consumer ID=0, messageId = 25,526,829,572 queue = users.queue] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.individualAcknowledge(ServerConsumerImpl.java:983) [artemis-server-2.20.0.jar:2.20.0] at org.apache.activemq.artemis.core.server.impl.ServerSessionImpl.individualAcknowledge(ServerSessionImpl.java:1285) [artemis-server-2.20.0.jar:2.20.0] at org.apache.activemq.artemis.core.protocol.core.ServerSessionPacketHandler.slowPacketHandler(ServerSessionPacketHandler.java:594) [artemis-server-2.20.0.jar:2.20.0] at org.apache.activemq.artemis.core.protocol.core.ServerSessionPacketHandler.onMessagePacket(ServerSessionPacketHandler.java:298) [artemis-server-2.20.0.jar:2.20.0] at org.apache.activemq.artemis.utils.actors.Actor.doTask(Actor.java:33) [artemis-commons-2.20.0.jar:] at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:65) [artemis-commons-2.20.0.jar:] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [artemis-commons-2.20.0.jar:] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [artemis-commons-2.20.0.jar:] at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:65) [artemis-commons-2.20.0.jar:] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [java.base:] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [java.base:] at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [artemis-commons-2.20.0.jar:] There wasn't problem when using client in older service with Java 8 and artemis-jms-client:2.19.1 (becase 2.20.0+ are meant for Java 11+) and in other service that used Java 17, Spring Boot 2.7 and artemis-jms-client:2.20.0. After migration to Spring Boot 3.x (tried 3.0 and 3.1) the problem appeared and I tried upgrading server and client but nothing changes. There wasn't any changes in listener implementation (the only change is the use of jakarta.jms.* imports)

Are there any options on what I can do and what can be missing/incompatible?

I tried downgrading service to the use of JMS 3.0, upgrading Artemis ActiveMQ to 2.28.0 and clients to 2.28.0 or without upgrade (2.20.0)- each in different combinations of server/client (as of Artemis docs I upgraded broker first and then clients), but the error logs are still there:

2024-03-04 14:42:13,800 ERROR [org.apache.activemq.artemis.core.server] AMQ224016: Caught exception org.apache.activemq.artemis.api.core.ActiveMQIllegalStateException: AMQ229027: Could not find reference on consumer ID=0, messageId = 25528494589 queue = users.queue at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.individualAcknowledge(ServerConsumerImpl.java:982) ~[artemis-server-2.28.0.jar:2.28.0] This generates like 500MB of logs every day in my case, and before that there was like only ~100KB of server logs each day


Источник: https://stackoverflow.com/questions/781 ... -migration