Uploaded image for project: 'AMQ Broker'
  1. AMQ Broker
  2. ENTMQBR-612

AMQ222109: Timed out waiting for write lock on consumer. Check the Thread dump

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Critical Critical
    • A-MQ 7.0.0.CR1
    • A-MQ 7.0.0.ER18
    • None
    • Hide

      In broker instance

      rm -rf data lock log tmp

      Edit files in broker instance the following way

      diff --git a/etc/artemis.profile b/etc/artemis.profile
index 78ba836..f995c67 100644
--- a/etc/artemis.profile
+++ b/etc/artemis.profile
@@ -28,9 +28,9 @@ JAVA_ARGS=" -XX:+PrintClassHistogram -XX:+UseG1GC -XX:+AggressiveOpts -XX:+UseFa
 #
 # There might be options that you only want to enable on specifc commands, like setting a JMX port
 # See https://issues.apache.org/jira/browse/ARTEMIS-318
-#if [ "$1" = "run" ]; then
-#  JAVA_ARGS="$JAVA_ARGS -Dcom.sun.management.jmxremote=true -Dcom.sun.management.jmxremote.port=1099 -Dcom.sun.management.jmxremote.rmi.port=1098 -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false"
-#fi
+if [ "$1" = "run" ]; then
+  JAVA_ARGS="$JAVA_ARGS -Dcom.sun.management.jmxremote=true -Dcom.sun.management.jmxremote.port=1099 -Dcom.sun.management.jmxremote.rmi.port=1098 -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false"
+fi
 
 #
 # Logs Safepoints JVM pauses: Uncomment to enable them
diff --git a/etc/broker.xml b/etc/broker.xml
index 736ff09..597beec 100644
--- a/etc/broker.xml
+++ b/etc/broker.xml
@@ -25,7 +25,7 @@ under the License.
    <core xmlns="urn:activemq:core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="urn:activemq:core ">
 
-      <name>0.0.0.0</name>
+      <name>amq</name>
 
       <persistence-enabled>true</persistence-enabled>
 
@@ -89,7 +89,7 @@ under the License.
 
       <!-- once the disk hits this limit the system will block, or close the connection in certain protocols
            that won't support flow control. -->
-      <max-disk-usage>90</max-disk-usage>
+      <max-disk-usage>100</max-disk-usage>
 
       <!-- the system will enter into page mode once you hit this limit.
            This is an estimate in bytes of how much the messages are using in memory -->
@@ -163,6 +163,10 @@ under the License.
             <auto-create-addresses>true</auto-create-addresses>
             <auto-create-jms-queues>true</auto-create-jms-queues>
             <auto-create-jms-topics>true</auto-create-jms-topics>
+
+            <slow-consumer-threshold>1</slow-consumer-threshold>
+            <slow-consumer-policy>KILL</slow-consumer-policy>
+            <slow-consumer-check-period>5</slow-consumer-check-period>
          </address-setting>
       </address-settings>

      Run

      ./aac5_receiver.py -b 127.0.0.1:5672/activemq.notifications --log-msgs dict --count 1 multiple times, untill it gets stuck (does not exit almost immedially). Then kill it with Ctrl+C

      Finally run ./aac5_receiver.py -b 127.0.0.1:5672/activemq.notifications --log-msgs dict --count 10. This will be stuck the first time. Wait a moment and Crrl+C it as well. At this point, broker prints error message you can see in the body of this ticket.

      Show
      In broker instance rm -rf data lock log tmp Edit files in broker instance the following way diff --git a/etc/artemis.profile b/etc/artemis.profile index 78ba836..f995c67 100644 --- a/etc/artemis.profile +++ b/etc/artemis.profile @@ -28,9 +28,9 @@ JAVA_ARGS=" -XX:+PrintClassHistogram -XX:+UseG1GC -XX:+AggressiveOpts -XX:+UseFa # # There might be options that you only want to enable on specifc commands, like setting a JMX port # See https://issues.apache.org/jira/browse/ARTEMIS-318 -#if [ "$1" = "run" ]; then -# JAVA_ARGS="$JAVA_ARGS -Dcom.sun.management.jmxremote=true -Dcom.sun.management.jmxremote.port=1099 -Dcom.sun.management.jmxremote.rmi.port=1098 -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false" -#fi +if [ "$1" = "run" ]; then + JAVA_ARGS="$JAVA_ARGS -Dcom.sun.management.jmxremote=true -Dcom.sun.management.jmxremote.port=1099 -Dcom.sun.management.jmxremote.rmi.port=1098 -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false" +fi # # Logs Safepoints JVM pauses: Uncomment to enable them diff --git a/etc/broker.xml b/etc/broker.xml index 736ff09..597beec 100644 --- a/etc/broker.xml +++ b/etc/broker.xml @@ -25,7 +25,7 @@ under the License. <core xmlns="urn:activemq:core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:activemq:core "> - <name>0.0.0.0</name> + <name>amq</name> <persistence-enabled>true</persistence-enabled> @@ -89,7 +89,7 @@ under the License. <!-- once the disk hits this limit the system will block, or close the connection in certain protocols that won't support flow control. --> - <max-disk-usage>90</max-disk-usage> + <max-disk-usage>100</max-disk-usage> <!-- the system will enter into page mode once you hit this limit. This is an estimate in bytes of how much the messages are using in memory --> @@ -163,6 +163,10 @@ under the License. <auto-create-addresses>true</auto-create-addresses> <auto-create-jms-queues>true</auto-create-jms-queues> <auto-create-jms-topics>true</auto-create-jms-topics> + + <slow-consumer-threshold>1</slow-consumer-threshold> + <slow-consumer-policy>KILL</slow-consumer-policy> + <slow-consumer-check-period>5</slow-consumer-check-period> </address-setting> </address-settings> Run ./aac5_receiver.py -b 127.0.0.1:5672/activemq.notifications --log-msgs dict --count 1 multiple times, untill it gets stuck (does not exit almost immedially). Then kill it with Ctrl+C Finally run ./aac5_receiver.py -b 127.0.0.1:5672/activemq.notifications --log-msgs dict --count 10 . This will be stuck the first time. Wait a moment and Crrl+C it as well. At this point, broker prints error message you can see in the body of this ticket. 

      $ bin/artemis run         
     _        _               _
    / \  ____| |_  ___ __  __(_) _____
   / _ \|  _ \ __|/ _ \  \/  | |/  __/
  / ___ \ | \/ |_/  __/ |\/| | |\___ \
 /_/   \_\|   \__\____|_|  |_|_|/___ /
 Apache ActiveMQ Artemis 2.1.0-SNAPSHOT


14:32:05,139 INFO  [org.apache.activemq.artemis.integration.bootstrap] AMQ101000: Starting ActiveMQ Artemis Server
14:32:05,208 INFO  [org.apache.activemq.artemis.core.server] AMQ221000: live Message Broker is starting with configuration Broker Configuration (clustered=false,journalDirectory=./data/journal,bindingsDirectory=./data/bindings,largeMessagesDirectory=./data/large-messages,pagingDirectory=./data/paging)
14:32:05,235 INFO  [org.apache.activemq.artemis.core.server] AMQ221013: Using NIO Journal
14:32:05,311 ERROR [org.apache.activemq.artemis.core.server] AMQ224076: No cluster locator found. This server will not participate in a cluster. Ensure a valid cluster-connection is configured.
14:32:05,324 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-server]. Adding protocol support for: CORE
14:32:05,325 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-amqp-protocol]. Adding protocol support for: AMQP
14:32:05,326 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-hornetq-protocol]. Adding protocol support for: HORNETQ
14:32:05,326 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-mqtt-protocol]. Adding protocol support for: MQTT
14:32:05,326 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-openwire-protocol]. Adding protocol support for: OPENWIRE
14:32:05,327 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-stomp-protocol]. Adding protocol support for: STOMP
14:32:05,450 INFO  [org.apache.activemq.artemis.core.server] AMQ221034: Waiting indefinitely to obtain live lock
14:32:05,450 INFO  [org.apache.activemq.artemis.core.server] AMQ221035: Live Server Obtained live lock
14:32:05,917 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying queue DLQ
14:32:05,987 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying queue ExpiryQueue
14:32:06,301 INFO  [org.apache.activemq.artemis.core.server] AMQ221020: Started EPOLL Acceptor at 0.0.0.0:61616 for protocols [CORE,MQTT,AMQP,STOMP,HORNETQ,OPENWIRE]
14:32:06,303 INFO  [org.apache.activemq.artemis.core.server] AMQ221020: Started EPOLL Acceptor at 0.0.0.0:5445 for protocols [HORNETQ,STOMP]
14:32:06,304 INFO  [org.apache.activemq.artemis.core.server] AMQ221020: Started EPOLL Acceptor at 0.0.0.0:5672 for protocols [AMQP]
14:32:06,306 INFO  [org.apache.activemq.artemis.core.server] AMQ221020: Started EPOLL Acceptor at 0.0.0.0:1883 for protocols [MQTT]
14:32:06,307 INFO  [org.apache.activemq.artemis.core.server] AMQ221020: Started EPOLL Acceptor at 0.0.0.0:61613 for protocols [STOMP]
14:32:06,314 INFO  [org.apache.activemq.artemis.core.server] AMQ221007: Server is now live
14:32:06,314 INFO  [org.apache.activemq.artemis.core.server] AMQ221001: Apache ActiveMQ Artemis Message Broker version 2.1.0-SNAPSHOT [amq, nodeID=36d52f2c-16d7-11e7-a58e-1a06fdfcf5b7] 
14:32:06,797 INFO  [org.apache.activemq.artemis] AMQ241001: HTTP Server started at http://localhost:8161
14:32:06,797 INFO  [org.apache.activemq.artemis] AMQ241002: Artemis Jolokia REST API available at http://localhost:8161/jolokia
14:32:27,038 WARN  [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session 43d6ce01-16d7-11e7-a58e-1a06fdfcf5b7
14:32:27,042 WARN  [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session 43d6ce01-16d7-11e7-a58e-1a06fdfcf5b7
14:32:29,825 INFO  [org.apache.activemq.artemis.core.server] AMQ221048: Consumer 44990c92-16d7-11e7-a58e-1a06fdfcf5b7:0 attached to queue 'activemq.notifications' from /127.0.0.1:58640 identified as 'slow.' Expected consumption rate: 1 msgs/second; actual consumption rate: 0.65 msgs/second.
14:32:29,841 WARN  [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: AMQ119005: connections for /127.0.0.1:58640 closed by management [code=INTERNAL_ERROR]
14:32:39,842 WARN  [org.apache.activemq.artemis.core.client] AMQ212041: Timed out waiting for netty channel to close
14:32:47,270 WARN  [org.apache.activemq.artemis.core.server] AMQ222174: Queue activemq.notifications, on address=activemq.notifications, is taking too long to flush deliveries. Watch out for frozen clients.
14:32:53,818 WARN  [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session 4f521af3-16d7-11e7-a58e-1a06fdfcf5b7
14:32:53,819 WARN  [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session 4f521af3-16d7-11e7-a58e-1a06fdfcf5b7
14:32:58,294 WARN  [org.apache.activemq.artemis.core.server] AMQ222109: Timed out waiting for write lock on consumer. Check the Thread dump
14:32:58,311 WARN  [org.apache.activemq.artemis.core.server] AMQ222199: Thread dump: AMQ119001: Generating thread dump
*******************************************************************************
===============================================================================
AMQ119002: Thread Thread[RMI TCP Accept-1098,5,system] name = RMI TCP Accept-1098 id = 11 group = java.lang.ThreadGroup[name=system,maxpri=10]

java.net.PlainSocketImpl.socketAccept(Native Method)
java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:409)
java.net.ServerSocket.implAccept(ServerSocket.java:545)
java.net.ServerSocket.accept(ServerSocket.java:513)
sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(TCPTransport.java:400)
sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(TCPTransport.java:372)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Reference Handler,10,system] name = Reference Handler id = 2 group = java.lang.ThreadGroup[name=system,maxpri=10]

java.lang.Object.wait(Native Method)
java.lang.Object.wait(Object.java:502)
java.lang.ref.Reference.tryHandlePending(Reference.java:191)
java.lang.ref.Reference$ReferenceHandler.run(Reference.java:153)
===============================================================================
AMQ119002: Thread Thread[Thread-2 (activemq-netty-threads-1603177117),5,activemq-netty-threads-1603177117] name = Thread-2 (activemq-netty-threads-1603177117) id = 47 group = java.lang.ThreadGroup[name=activemq-netty-threads-1603177117,maxpri=10]

io.netty.channel.epoll.Native.epollWait0(Native Method)
io.netty.channel.epoll.Native.epollWait(Native.java:117)
io.netty.channel.epoll.EpollEventLoop.epollWait(EpollEventLoop.java:231)
io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:255)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Thread-1 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$3@78b729e6-111156771),5,ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$3@78b729e6-111156771] name = Thread-1 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$3@78b729e6-111156771) id = 45 group = java.lang.ThreadGroup[name=ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$3@78b729e6-111156771,maxpri=10]

sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
org.apache.activemq.artemis.utils.ActiveMQThreadPoolExecutor$ThreadPoolQueue.poll(ActiveMQThreadPoolExecutor.java:124)
org.apache.activemq.artemis.utils.ActiveMQThreadPoolExecutor$ThreadPoolQueue.poll(ActiveMQThreadPoolExecutor.java:44)
java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1066)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Thread-0 (ActiveMQ-scheduled-threads-487075464),5,ActiveMQ-scheduled-threads-487075464] name = Thread-0 (ActiveMQ-scheduled-threads-487075464) id = 20 group = java.lang.ThreadGroup[name=ActiveMQ-scheduled-threads-487075464,maxpri=10]

sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Thread-0 (activemq-netty-threads-1208825205),5,activemq-netty-threads-1208825205] name = Thread-0 (activemq-netty-threads-1208825205) id = 30 group = java.lang.ThreadGroup[name=activemq-netty-threads-1208825205,maxpri=10]

io.netty.channel.epoll.Native.epollWait0(Native Method)
io.netty.channel.epoll.Native.epollWait(Native.java:117)
io.netty.channel.epoll.EpollEventLoop.epollWait(EpollEventLoop.java:231)
io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:255)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Signal Dispatcher,9,system] name = Signal Dispatcher id = 5 group = java.lang.ThreadGroup[name=system,maxpri=10]

===============================================================================
AMQ119002: Thread Thread[Thread-2 (ActiveMQ-scheduled-threads-487075464),5,ActiveMQ-scheduled-threads-487075464] name = Thread-2 (ActiveMQ-scheduled-threads-487075464) id = 23 group = java.lang.ThreadGroup[name=ActiveMQ-scheduled-threads-487075464,maxpri=10]

sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[qtp1351478315-38,5,main] name = qtp1351478315-38 id = 38 group = java.lang.ThreadGroup[name=main,maxpri=10]

sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
org.eclipse.jetty.util.BlockingArrayQueue.poll(BlockingArrayQueue.java:392)
org.eclipse.jetty.util.thread.QueuedThreadPool.idleJobPoll(QueuedThreadPool.java:564)
org.eclipse.jetty.util.thread.QueuedThreadPool.access$800(QueuedThreadPool.java:49)
org.eclipse.jetty.util.thread.QueuedThreadPool$2.run(QueuedThreadPool.java:627)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[qtp1351478315-37,5,main] name = qtp1351478315-37 id = 37 group = java.lang.ThreadGroup[name=main,maxpri=10]

sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
org.eclipse.jetty.util.BlockingArrayQueue.poll(BlockingArrayQueue.java:392)
org.eclipse.jetty.util.thread.QueuedThreadPool.idleJobPoll(QueuedThreadPool.java:564)
org.eclipse.jetty.util.thread.QueuedThreadPool.access$800(QueuedThreadPool.java:49)
org.eclipse.jetty.util.thread.QueuedThreadPool$2.run(QueuedThreadPool.java:627)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[threadDeathWatcher-2-1,1,activemq-netty-threads-1603177117] name = threadDeathWatcher-2-1 id = 44 group = java.lang.ThreadGroup[name=activemq-netty-threads-1603177117,maxpri=10]

java.lang.Thread.sleep(Native Method)
io.netty.util.ThreadDeathWatcher$Watcher.run(ThreadDeathWatcher.java:150)
io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[qtp1351478315-36-acceptor-0@28147235-ServerConnector@26d39947{HTTP/1.1,[http/1.1]}{localhost:8161},3,main] name = qtp1351478315-36-acceptor-0@28147235-ServerConnector@26d39947{HTTP/1.1,[http/1.1]}{localhost:8161} id = 36 group = java.lang.ThreadGroup[name=main,maxpri=10]

sun.nio.ch.ServerSocketChannelImpl.accept0(Native Method)
sun.nio.ch.ServerSocketChannelImpl.accept(ServerSocketChannelImpl.java:422)
sun.nio.ch.ServerSocketChannelImpl.accept(ServerSocketChannelImpl.java:250)
org.eclipse.jetty.server.ServerConnector.accept(ServerConnector.java:355)
org.eclipse.jetty.server.AbstractConnector$Acceptor.run(AbstractConnector.java:595)
org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:672)
org.eclipse.jetty.util.thread.QueuedThreadPool$2.run(QueuedThreadPool.java:590)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[qtp1351478315-32,5,main] name = qtp1351478315-32 id = 32 group = java.lang.ThreadGroup[name=main,maxpri=10]

sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
sun.nio.ch.SelectorImpl.select(SelectorImpl.java:101)
org.eclipse.jetty.io.ManagedSelector$SelectorProducer.select(ManagedSelector.java:297)
org.eclipse.jetty.io.ManagedSelector$SelectorProducer.produce(ManagedSelector.java:250)
org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.produceConsume(ExecuteProduceConsume.java:147)
org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.produce(ExecuteProduceConsume.java:97)
org.eclipse.jetty.io.ManagedSelector$1.run(ManagedSelector.java:77)
org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:672)
org.eclipse.jetty.util.thread.QueuedThreadPool$2.run(QueuedThreadPool.java:590)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Thread-3 (ActiveMQ-scheduled-threads-487075464),5,ActiveMQ-scheduled-threads-487075464] name = Thread-3 (ActiveMQ-scheduled-threads-487075464) id = 24 group = java.lang.ThreadGroup[name=ActiveMQ-scheduled-threads-487075464,maxpri=10]

sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[DestroyJavaVM,5,main] name = DestroyJavaVM id = 41 group = java.lang.ThreadGroup[name=main,maxpri=10]

===============================================================================
AMQ119002: Thread Thread[Thread-0 (activemq-netty-threads-1603177117),5,activemq-netty-threads-1603177117] name = Thread-0 (activemq-netty-threads-1603177117) id = 29 group = java.lang.ThreadGroup[name=activemq-netty-threads-1603177117,maxpri=10]

io.netty.channel.epoll.Native.epollWait0(Native Method)
io.netty.channel.epoll.Native.epollWait(Native.java:117)
io.netty.channel.epoll.EpollEventLoop.epollWait(EpollEventLoop.java:231)
io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:255)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[activemq-buffer-timeout,5,main] name = activemq-buffer-timeout id = 19 group = java.lang.ThreadGroup[name=main,maxpri=10]

sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:836)
java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:997)
java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1304)
java.util.concurrent.Semaphore.acquire(Semaphore.java:312)
org.apache.activemq.artemis.core.io.buffer.TimedBuffer$CheckTimer.run(TimedBuffer.java:390)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[RMI TCP Accept-1099,5,system] name = RMI TCP Accept-1099 id = 12 group = java.lang.ThreadGroup[name=system,maxpri=10]

java.net.PlainSocketImpl.socketAccept(Native Method)
java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:409)
java.net.ServerSocket.implAccept(ServerSocket.java:545)
java.net.ServerSocket.accept(ServerSocket.java:513)
sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(TCPTransport.java:400)
sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(TCPTransport.java:372)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Thread-1 (activemq-netty-threads-1603177117),5,activemq-netty-threads-1603177117] name = Thread-1 (activemq-netty-threads-1603177117) id = 43 group = java.lang.ThreadGroup[name=activemq-netty-threads-1603177117,maxpri=10]

io.netty.channel.epoll.Native.epollWait0(Native Method)
io.netty.channel.epoll.Native.epollWait(Native.java:117)
io.netty.channel.epoll.EpollEventLoop.epollWait(EpollEventLoop.java:231)
io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:255)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Thread-0 (activemq-netty-threads-1823541245),5,activemq-netty-threads-1823541245] name = Thread-0 (activemq-netty-threads-1823541245) id = 28 group = java.lang.ThreadGroup[name=activemq-netty-threads-1823541245,maxpri=10]

io.netty.channel.epoll.Native.epollWait0(Native Method)
io.netty.channel.epoll.Native.epollWait(Native.java:117)
io.netty.channel.epoll.EpollEventLoop.epollWait(EpollEventLoop.java:231)
io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:255)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[qtp1351478315-34,5,main] name = qtp1351478315-34 id = 34 group = java.lang.ThreadGroup[name=main,maxpri=10]

sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
sun.nio.ch.SelectorImpl.select(SelectorImpl.java:101)
org.eclipse.jetty.io.ManagedSelector$SelectorProducer.select(ManagedSelector.java:297)
org.eclipse.jetty.io.ManagedSelector$SelectorProducer.produce(ManagedSelector.java:250)
org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.produceConsume(ExecuteProduceConsume.java:147)
org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.produce(ExecuteProduceConsume.java:97)
org.eclipse.jetty.io.ManagedSelector$1.run(ManagedSelector.java:77)
org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:672)
org.eclipse.jetty.util.thread.QueuedThreadPool$2.run(QueuedThreadPool.java:590)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Thread-0 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$3@78b729e6-111156771),5,ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$3@78b729e6-111156771] name = Thread-0 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$3@78b729e6-111156771) id = 42 group = java.lang.ThreadGroup[name=ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$3@78b729e6-111156771,maxpri=10]

sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
org.apache.activemq.artemis.utils.ActiveMQThreadPoolExecutor$ThreadPoolQueue.poll(ActiveMQThreadPoolExecutor.java:124)
org.apache.activemq.artemis.utils.ActiveMQThreadPoolExecutor$ThreadPoolQueue.poll(ActiveMQThreadPoolExecutor.java:44)
java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1066)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Scheduler-945834881,5,main] name = Scheduler-945834881 id = 40 group = java.lang.ThreadGroup[name=main,maxpri=10]

sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)
java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Thread-0 (activemq-netty-threads-1267556427),5,activemq-netty-threads-1267556427] name = Thread-0 (activemq-netty-threads-1267556427) id = 31 group = java.lang.ThreadGroup[name=activemq-netty-threads-1267556427,maxpri=10]

io.netty.channel.epoll.Native.epollWait0(Native Method)
io.netty.channel.epoll.Native.epollWait(Native.java:117)
io.netty.channel.epoll.EpollEventLoop.epollWait(EpollEventLoop.java:231)
io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:255)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Finalizer,8,system] name = Finalizer id = 3 group = java.lang.ThreadGroup[name=system,maxpri=10]

java.lang.Object.wait(Native Method)
java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:143)
java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:164)
java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:209)
===============================================================================
AMQ119002: Thread Thread[Thread-1 (ActiveMQ-IO-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$4@23986957-603443293),5,ActiveMQ-IO-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$4@23986957-603443293] name = Thread-1 (ActiveMQ-IO-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$4@23986957-603443293) id = 46 group = java.lang.ThreadGroup[name=ActiveMQ-IO-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$4@23986957-603443293,maxpri=10]

sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460)
java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:362)
java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:941)
java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1066)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Thread-2 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$3@78b729e6-111156771),5,ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$3@78b729e6-111156771] name = Thread-2 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$3@78b729e6-111156771) id = 48 group = java.lang.ThreadGroup[name=ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$3@78b729e6-111156771,maxpri=10]

java.lang.Thread.dumpThreads(Native Method)
java.lang.Thread.getAllStackTraces(Thread.java:1607)
org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.threadDump(ActiveMQServerImpl.java:796)
org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.lockDelivery(ServerConsumerImpl.java:651)
org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.setStarted(ServerConsumerImpl.java:625)
org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.close(ServerConsumerImpl.java:450)
org.apache.activemq.artemis.protocol.amqp.broker.AMQPSessionCallback$2.run(AMQPSessionCallback.java:276)
org.apache.activemq.artemis.utils.OrderedExecutorFactory$OrderedExecutor$ExecutorTask.run(OrderedExecutorFactory.java:101)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[qtp1351478315-39,5,main] name = qtp1351478315-39 id = 39 group = java.lang.ThreadGroup[name=main,maxpri=10]

sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
org.eclipse.jetty.util.BlockingArrayQueue.poll(BlockingArrayQueue.java:392)
org.eclipse.jetty.util.thread.QueuedThreadPool.idleJobPoll(QueuedThreadPool.java:564)
org.eclipse.jetty.util.thread.QueuedThreadPool.access$800(QueuedThreadPool.java:49)
org.eclipse.jetty.util.thread.QueuedThreadPool$2.run(QueuedThreadPool.java:627)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Thread-4 (ActiveMQ-scheduled-threads-487075464),5,ActiveMQ-scheduled-threads-487075464] name = Thread-4 (ActiveMQ-scheduled-threads-487075464) id = 26 group = java.lang.ThreadGroup[name=ActiveMQ-scheduled-threads-487075464,maxpri=10]

org.apache.activemq.artemis.protocol.amqp.proton.handler.ProtonHandler.close(ProtonHandler.java:237)
org.apache.activemq.artemis.protocol.amqp.proton.AMQPConnectionContext.close(AMQPConnectionContext.java:144)
org.apache.activemq.artemis.protocol.amqp.broker.AMQPConnectionCallback.close(AMQPConnectionCallback.java:118)
org.apache.activemq.artemis.protocol.amqp.broker.AMQPConnectionCallback.connectionFailed(AMQPConnectionCallback.java:197)
org.apache.activemq.artemis.spi.core.protocol.AbstractRemotingConnection.callFailureListeners(AbstractRemotingConnection.java:67)
org.apache.activemq.artemis.protocol.amqp.broker.ActiveMQProtonRemotingConnection.fail(ActiveMQProtonRemotingConnection.java:77)
org.apache.activemq.artemis.spi.core.protocol.AbstractRemotingConnection.fail(AbstractRemotingConnection.java:210)
org.apache.activemq.artemis.core.server.impl.QueueImpl$SlowConsumerReaperRunnable.run(QueueImpl.java:3189)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Thread-1 (ActiveMQ-scheduled-threads-487075464),5,ActiveMQ-scheduled-threads-487075464] name = Thread-1 (ActiveMQ-scheduled-threads-487075464) id = 21 group = java.lang.ThreadGroup[name=ActiveMQ-scheduled-threads-487075464,maxpri=10]

sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)
java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[qtp1351478315-35-lowPrioSelector,1,main] name = qtp1351478315-35-lowPrioSelector id = 35 group = java.lang.ThreadGroup[name=main,maxpri=10]

org.eclipse.jetty.io.ManagedSelector$SelectorProducer.produce(ManagedSelector.java:240)
org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume.produce(ProduceExecuteConsume.java:75)
org.eclipse.jetty.io.ManagedSelector$2.run(ManagedSelector.java:97)
org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:672)
org.eclipse.jetty.util.thread.QueuedThreadPool$2.run(QueuedThreadPool.java:590)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Thread-3 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$3@78b729e6-111156771),5,ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$3@78b729e6-111156771] name = Thread-3 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$3@78b729e6-111156771) id = 49 group = java.lang.ThreadGroup[name=ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$3@78b729e6-111156771,maxpri=10]

org.apache.activemq.artemis.protocol.amqp.proton.ProtonServerSenderContext.deliverMessage(ProtonServerSenderContext.java:621)
org.apache.activemq.artemis.protocol.amqp.broker.AMQPSessionCallback.sendMessage(AMQPSessionCallback.java:506)
org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1050)
org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:430)
org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2649)
org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:2138)
org.apache.activemq.artemis.core.server.impl.QueueImpl.access$1700(QueueImpl.java:102)
org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2882)
org.apache.activemq.artemis.utils.OrderedExecutorFactory$OrderedExecutor$ExecutorTask.run(OrderedExecutorFactory.java:101)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Thread-3 (activemq-netty-threads-1603177117),5,activemq-netty-threads-1603177117] name = Thread-3 (activemq-netty-threads-1603177117) id = 50 group = java.lang.ThreadGroup[name=activemq-netty-threads-1603177117,maxpri=10]

org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.setStarted(ServerConsumerImpl.java:625)
org.apache.activemq.artemis.core.server.impl.ServerSessionImpl.setStarted(ServerSessionImpl.java:1525)
org.apache.activemq.artemis.core.server.impl.ServerSessionImpl.doClose(ServerSessionImpl.java:348)
org.apache.activemq.artemis.core.server.impl.ServerSessionImpl$1.done(ServerSessionImpl.java:1238)
org.apache.activemq.artemis.core.persistence.impl.journal.OperationContextImpl.executeOnCompletion(OperationContextImpl.java:181)
org.apache.activemq.artemis.core.persistence.impl.journal.OperationContextImpl.executeOnCompletion(OperationContextImpl.java:130)
org.apache.activemq.artemis.core.server.impl.ServerSessionImpl.close(ServerSessionImpl.java:1230)
org.apache.activemq.artemis.protocol.amqp.broker.AMQPSessionCallback.close(AMQPSessionCallback.java:310)
org.apache.activemq.artemis.protocol.amqp.proton.AMQPSessionContext.close(AMQPSessionContext.java:132)
org.apache.activemq.artemis.protocol.amqp.proton.AMQPConnectionContext.onRemoteClose(AMQPConnectionContext.java:376)
org.apache.activemq.artemis.protocol.amqp.proton.handler.Events.dispatch(Events.java:38)
org.apache.activemq.artemis.protocol.amqp.proton.handler.ProtonHandler.dispatch(ProtonHandler.java:299)
org.apache.activemq.artemis.protocol.amqp.proton.handler.ProtonHandler.flush(ProtonHandler.java:232)
org.apache.activemq.artemis.protocol.amqp.proton.handler.ProtonHandler.inputBuffer(ProtonHandler.java:201)
org.apache.activemq.artemis.protocol.amqp.proton.AMQPConnectionContext.inputBuffer(AMQPConnectionContext.java:120)
org.apache.activemq.artemis.protocol.amqp.broker.ActiveMQProtonRemotingConnection.bufferReceived(ActiveMQProtonRemotingConnection.java:138)
org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:630)
org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:69)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359)
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351)
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359)
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:1018)
io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:402)
io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:307)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Thread-0 (ActiveMQ-IO-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$4@23986957-603443293),5,ActiveMQ-IO-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$4@23986957-603443293] name = Thread-0 (ActiveMQ-IO-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$4@23986957-603443293) id = 22 group = java.lang.ThreadGroup[name=ActiveMQ-IO-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$4@23986957-603443293,maxpri=10]

sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460)
java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:362)
java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:941)
java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1066)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[ActiveMQ Artemis Server Shutdown Timer,5,main] name = ActiveMQ Artemis Server Shutdown Timer id = 14 group = java.lang.ThreadGroup[name=main,maxpri=10]

java.lang.Object.wait(Native Method)
java.util.TimerThread.mainLoop(Timer.java:552)
java.util.TimerThread.run(Timer.java:505)
===============================================================================
AMQ119002: Thread Thread[activemq-failure-check-thread,5,main] name = activemq-failure-check-thread id = 25 group = java.lang.ThreadGroup[name=main,maxpri=10]

sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037)
java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328)
java.util.concurrent.CountDownLatch.await(CountDownLatch.java:277)
org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl$FailureCheckAndFlushThread.run(RemotingServiceImpl.java:729)
===============================================================================
AMQ119002: Thread Thread[Thread-4 (activemq-netty-threads-1603177117),5,activemq-netty-threads-1603177117] name = Thread-4 (activemq-netty-threads-1603177117) id = 51 group = java.lang.ThreadGroup[name=activemq-netty-threads-1603177117,maxpri=10]

io.netty.channel.epoll.Native.epollWait0(Native Method)
io.netty.channel.epoll.Native.epollWait(Native.java:117)
io.netty.channel.epoll.EpollEventLoop.epollWait(EpollEventLoop.java:231)
io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:255)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[RMI TCP Accept-0,5,system] name = RMI TCP Accept-0 id = 13 group = java.lang.ThreadGroup[name=system,maxpri=10]

java.net.PlainSocketImpl.socketAccept(Native Method)
java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:409)
java.net.ServerSocket.implAccept(ServerSocket.java:545)
java.net.ServerSocket.accept(ServerSocket.java:513)
sun.management.jmxremote.LocalRMIServerSocketFactory$1.accept(LocalRMIServerSocketFactory.java:52)
sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(TCPTransport.java:400)
sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(TCPTransport.java:372)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[qtp1351478315-33-lowPrioSelector,1,main] name = qtp1351478315-33-lowPrioSelector id = 33 group = java.lang.ThreadGroup[name=main,maxpri=10]

org.eclipse.jetty.io.ManagedSelector$SelectorProducer.produce(ManagedSelector.java:240)
org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume.produce(ProduceExecuteConsume.java:75)
org.eclipse.jetty.io.ManagedSelector$2.run(ManagedSelector.java:97)
org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:672)
org.eclipse.jetty.util.thread.QueuedThreadPool$2.run(QueuedThreadPool.java:590)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119002: Thread Thread[Thread-0 (activemq-netty-threads-1225038340),5,activemq-netty-threads-1225038340] name = Thread-0 (activemq-netty-threads-1225038340) id = 27 group = java.lang.ThreadGroup[name=activemq-netty-threads-1225038340,maxpri=10]

io.netty.channel.epoll.Native.epollWait0(Native Method)
io.netty.channel.epoll.Native.epollWait(Native.java:117)
io.netty.channel.epoll.EpollEventLoop.epollWait(EpollEventLoop.java:231)
io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:255)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
java.lang.Thread.run(Thread.java:745)
===============================================================================
AMQ119003: End Thread dump
*******************************************************************************

14:33:28,362 WARN  [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session 44990c92-16d7-11e7-a58e-1a06fdfcf5b7
14:33:28,362 WARN  [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session 44990c92-16d7-11e7-a58e-1a06fdfcf5b7

      If I then stop the broker with Ctrl+C, the following is printed

      ^C14:33:41,767 WARN  [org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptor] PagingStore(activemq.notifications) not initialized: java.lang.IllegalStateException: PagingStore(activemq.notifications) not initialized
        at org.apache.activemq.artemis.core.paging.impl.PagingStoreImpl.page(PagingStoreImpl.java:756) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.persistence.impl.journal.AbstractJournalStorageManager.addToPage(AbstractJournalStorageManager.java:1924) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.processRoute(PostOfficeImpl.java:1062) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:786) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:689) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:674) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:667) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.management.impl.ManagementServiceImpl.sendNotification(ManagementServiceImpl.java:659) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptor.stop(NettyAcceptor.java:561) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl.stop(RemotingServiceImpl.java:408) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.stop(ActiveMQServerImpl.java:940) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.stop(ActiveMQServerImpl.java:823) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.internalStop(ActiveMQServerImpl.java:683) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.exit(ActiveMQServerImpl.java:673) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.integration.FileBroker.stop(FileBroker.java:133) [artemis-cli-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.integration.FileBroker.exit(FileBroker.java:122) [artemis-cli-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.cli.commands.Run$2.run(Run.java:158) [artemis-cli-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]

14:33:41,773 WARN  [org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptor] PagingStore(activemq.notifications) not initialized: java.lang.IllegalStateException: PagingStore(activemq.notifications) not initialized
        at org.apache.activemq.artemis.core.paging.impl.PagingStoreImpl.page(PagingStoreImpl.java:756) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.persistence.impl.journal.AbstractJournalStorageManager.addToPage(AbstractJournalStorageManager.java:1924) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.processRoute(PostOfficeImpl.java:1062) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:786) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:689) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:674) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:667) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.management.impl.ManagementServiceImpl.sendNotification(ManagementServiceImpl.java:659) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptor.stop(NettyAcceptor.java:561) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl.stop(RemotingServiceImpl.java:408) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.stop(ActiveMQServerImpl.java:940) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.stop(ActiveMQServerImpl.java:823) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.internalStop(ActiveMQServerImpl.java:683) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.exit(ActiveMQServerImpl.java:673) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.integration.FileBroker.stop(FileBroker.java:133) [artemis-cli-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.integration.FileBroker.exit(FileBroker.java:122) [artemis-cli-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.cli.commands.Run$2.run(Run.java:158) [artemis-cli-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]

14:33:41,785 WARN  [org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptor] PagingStore(activemq.notifications) not initialized: java.lang.IllegalStateException: PagingStore(activemq.notifications) not initialized
        at org.apache.activemq.artemis.core.paging.impl.PagingStoreImpl.page(PagingStoreImpl.java:756) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.persistence.impl.journal.AbstractJournalStorageManager.addToPage(AbstractJournalStorageManager.java:1924) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.processRoute(PostOfficeImpl.java:1062) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:786) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:689) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:674) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:667) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.management.impl.ManagementServiceImpl.sendNotification(ManagementServiceImpl.java:659) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptor.stop(NettyAcceptor.java:561) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl.stop(RemotingServiceImpl.java:408) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.stop(ActiveMQServerImpl.java:940) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.stop(ActiveMQServerImpl.java:823) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.internalStop(ActiveMQServerImpl.java:683) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.exit(ActiveMQServerImpl.java:673) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.integration.FileBroker.stop(FileBroker.java:133) [artemis-cli-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.integration.FileBroker.exit(FileBroker.java:122) [artemis-cli-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.cli.commands.Run$2.run(Run.java:158) [artemis-cli-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]

14:33:41,800 WARN  [org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptor] PagingStore(activemq.notifications) not initialized: java.lang.IllegalStateException: PagingStore(activemq.notifications) not initialized
        at org.apache.activemq.artemis.core.paging.impl.PagingStoreImpl.page(PagingStoreImpl.java:756) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.persistence.impl.journal.AbstractJournalStorageManager.addToPage(AbstractJournalStorageManager.java:1924) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.processRoute(PostOfficeImpl.java:1062) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:786) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:689) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:674) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:667) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.management.impl.ManagementServiceImpl.sendNotification(ManagementServiceImpl.java:659) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptor.stop(NettyAcceptor.java:561) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl.stop(RemotingServiceImpl.java:408) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.stop(ActiveMQServerImpl.java:940) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.stop(ActiveMQServerImpl.java:823) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.internalStop(ActiveMQServerImpl.java:683) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.exit(ActiveMQServerImpl.java:673) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.integration.FileBroker.stop(FileBroker.java:133) [artemis-cli-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.integration.FileBroker.exit(FileBroker.java:122) [artemis-cli-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.cli.commands.Run$2.run(Run.java:158) [artemis-cli-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]

14:33:41,807 WARN  [org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptor] PagingStore(activemq.notifications) not initialized: java.lang.IllegalStateException: PagingStore(activemq.notifications) not initialized
        at org.apache.activemq.artemis.core.paging.impl.PagingStoreImpl.page(PagingStoreImpl.java:756) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.persistence.impl.journal.AbstractJournalStorageManager.addToPage(AbstractJournalStorageManager.java:1924) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.processRoute(PostOfficeImpl.java:1062) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:786) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:689) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:674) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:667) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.management.impl.ManagementServiceImpl.sendNotification(ManagementServiceImpl.java:659) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptor.stop(NettyAcceptor.java:561) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl.stop(RemotingServiceImpl.java:408) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.stop(ActiveMQServerImpl.java:940) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.stop(ActiveMQServerImpl.java:823) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.internalStop(ActiveMQServerImpl.java:683) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.exit(ActiveMQServerImpl.java:673) [artemis-server-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.integration.FileBroker.stop(FileBroker.java:133) [artemis-cli-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.integration.FileBroker.exit(FileBroker.java:122) [artemis-cli-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]
        at org.apache.activemq.artemis.cli.commands.Run$2.run(Run.java:158) [artemis-cli-2.1.0-SNAPSHOT.jar:2.1.0-SNAPSHOT]

14:33:41,862 INFO  [org.apache.activemq.artemis.core.server] AMQ221002: Apache ActiveMQ Artemis Message Broker version 2.1.0-SNAPSHOT [36d52f2c-16d7-11e7-a58e-1a06fdfcf5b7] stopped, uptime 1 minute

      In downstream versions, in ER17 and in Andy's snapshot, the ./aac5_receiver commands would immediatelly fail with

      % ./aac5_receiver.py -b 127.0.0.1:5672/activemq.notifications --log-msgs dict --count 1 
ERROR:root:Incorrect Routing Type for queue, expecting: ANYCAST
Traceback (most recent call last):
  File "./aac5_receiver.py", line 360, in <module>
    main()
  File "./aac5_receiver.py", line 354, in main
    container.run()
  File "/home/jdanek/.virtualenvs/p2dtests/lib/python2.7/site-packages/proton/reactor.py", line 133, in run
    while self.process(): pass
  File "/home/jdanek/.virtualenvs/p2dtests/lib/python2.7/site-packages/proton/reactor.py", line 159, in process
    self._check_errors()
  File "/home/jdanek/.virtualenvs/p2dtests/lib/python2.7/site-packages/proton/reactor.py", line 155, in _check_errors
    _compat.raise_(exc, value, tb)
  File "/home/jdanek/.virtualenvs/p2dtests/lib/python2.7/site-packages/proton/__init__.py", line 4050, in dispatch
    ev.dispatch(self.handler)
  File "/home/jdanek/.virtualenvs/p2dtests/lib/python2.7/site-packages/proton/__init__.py", line 3959, in dispatch
    result = dispatch(handler, type.method, self)
  File "/home/jdanek/.virtualenvs/p2dtests/lib/python2.7/site-packages/proton/__init__.py", line 3839, in dispatch
    return handler.on_unhandled(method, *args)
  File "/home/jdanek/Work/repos/dtests/dtests/node_data/clients/python/Aac5CoreClient.py", line 269, in on_unhandled
    raise ClientException("Link error: %s ..." % self._evaluate_endpoint_error(event.link, "link"))
Aac5CoreClient.ClientException: Link error: Incorrect Routing Type for queue, expecting: ANYCAST ...

            mtaylor1@redhat.com Martyn Taylor (Inactive)
            jdanek@redhat.com Jiri Daněk
            Jiri Daněk Jiri Daněk
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

              Created:
              Updated:
              Resolved: