Test Scenario:
- Start single server with deployed topic (JDBC store journal on DB2)
- Send 1000 Large Messages to topic.
- Slow and fast subscriber start consume messages from topic (there is set receive timeout 10 seconds)
Expected result: Check that all messages were received.
Actual result: Slow consumer does not finish and test timeouts after 1 hour
Suspected warning in server log:
14:24:01 12:24:01,642 WARN [org.apache.activemq.artemis.utils.actors.OrderedExecutor] (Thread-2 (ActiveMQ-PageExecutor-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$9@2219d905)) null: java.lang.AssertionError 14:24:01 at org.apache.activemq.artemis@2.21.0.redhat-00044//org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl$CoreLargeMessageDeliverer.deliver(ServerConsumerImpl.java:1361) 14:24:01 at org.apache.activemq.artemis@2.21.0.redhat-00044//org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl$2.run(ServerConsumerImpl.java:1224) 14:24:01 at org.apache.activemq.artemis.journal//org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:56) 14:24:01 at org.apache.activemq.artemis.journal//org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) 14:24:01 at org.apache.activemq.artemis.journal//org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:67) 14:24:01 at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) 14:24:01 at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) 14:24:01 at org.apache.activemq.artemis.journal//org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118)
Attaching client-thread-dump.txt from maven surefire process and server.log
This issue was not hit with File based journal.
- incorporates
-
JBEAP-25839 (8.0.z) Hanging slow subscriber with JDBC journal store
- New
- is related to
-
ENTMQBR-8496 Hanging slow subscriber with JDBC journal store
- Resolved