[jira] [Updated] (HIVE-14463) hcatalog server extensions test cases getting stuck

[Hari Sankar Sivarama Subramaniyan (JIRA)]

 [ 
https://issues.apache.org/jira/browse/HIVE-14463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Hari Sankar Sivarama Subramaniyan updated HIVE-14463:
-
   Resolution: Fixed
Fix Version/s: 2.2.0
   Status: Resolved  (was: Patch Available)

> hcatalog server extensions test cases getting stuck
> ---
>
> Key: HIVE-14463
> URL: https://issues.apache.org/jira/browse/HIVE-14463
> Project: Hive
>  Issue Type: Bug
>Affects Versions: 2.1.0
>Reporter: Rajat Khandelwal
>Assignee: Hari Sankar Sivarama Subramaniyan
> Fix For: 2.2.0
>
> Attachments: HIVE-14463.1.patch
>
>
> The module is getting stuck in tests and not coming out for as long as 2 
> days. 
> Specifically, TestMsgBusConnection is the test case which has this problem. I 
> ran the tests on local environment and took a thread dump after it got stuck. 
> {noformat}
> Full thread dump Java HotSpot(TM) 64-Bit Server VM (24.80-b11 mixed mode):
> "InactivityMonitor Async Task: 
> java.util.concurrent.ThreadPoolExecutor$Worker@2c040428[State = -1, empty 
> queue]" daemon prio=5 tid=0x7fe90d89e000 nid=0x8827 waiting on condition 
> [0x000117b74000]
>java.lang.Thread.State: TIMED_WAITING (parking)
>   at sun.misc.Unsafe.park(Native Method)
>   - parking to wait for  <0x00078166f0b8> (a 
> java.util.concurrent.SynchronousQueue$TransferStack)
>   at 
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:359)
>   at java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:942)
>   at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
>   at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
>   at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>   at java.lang.Thread.run(Thread.java:745)
> "InactivityMonitor Async Task: 
> java.util.concurrent.ThreadPoolExecutor$Worker@182a483f[State = -1, empty 
> queue]" daemon prio=5 tid=0x7fe90d801000 nid=0x585f waiting on condition 
> [0x00011786b000]
>java.lang.Thread.State: TIMED_WAITING (parking)
>   at sun.misc.Unsafe.park(Native Method)
>   - parking to wait for  <0x00078166f0b8> (a 
> java.util.concurrent.SynchronousQueue$TransferStack)
>   at 
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:359)
>   at java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:942)
>   at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
>   at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
>   at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>   at java.lang.Thread.run(Thread.java:745)
> "ActiveMQ Transport: tcp:///127.0.0.1:56883" daemon prio=5 
> tid=0x7fe90c83e800 nid=0x8403 runnable [0x0001196ab000]
>java.lang.Thread.State: RUNNABLE
>   at java.net.SocketInputStream.socketRead0(Native Method)
>   at java.net.SocketInputStream.read(SocketInputStream.java:152)
>   at java.net.SocketInputStream.read(SocketInputStream.java:122)
>   at 
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport$2.fill(TcpTransport.java:576)
>   at 
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport$2.read(TcpTransport.java:561)
>   at java.io.DataInputStream.readInt(DataInputStream.java:387)
>   at 
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:269)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:227)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
>   at java.lang.Thread.run(Thread.java:745)
> "ActiveMQ Transport: tcp://localhost/127.0.0.1:61616" prio=5 
> tid=0x7fe90b81e800 nid=0x8003 runnable [0x0001194a5000]
>java.lang.Thread.State: RUNNABLE
>   at java.net.SocketInputStream.socketRead0(Native Method)
>   at java.net.SocketInputStream.read(SocketInputStream.java:152)
>   at java.net.SocketInputSt

[jira] [Updated] (HIVE-14463) hcatalog server extensions test cases getting stuck

[Hari Sankar Sivarama Subramaniyan (JIRA)]

 [ 
https://issues.apache.org/jira/browse/HIVE-14463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Hari Sankar Sivarama Subramaniyan updated HIVE-14463:
-
Status: Patch Available  (was: Open)

> hcatalog server extensions test cases getting stuck
> ---
>
> Key: HIVE-14463
> URL: https://issues.apache.org/jira/browse/HIVE-14463
> Project: Hive
>  Issue Type: Bug
>Affects Versions: 2.1.0
>Reporter: Rajat Khandelwal
>Assignee: Hari Sankar Sivarama Subramaniyan
> Attachments: HIVE-14463.1.patch
>
>
> The module is getting stuck in tests and not coming out for as long as 2 
> days. 
> Specifically, TestMsgBusConnection is the test case which has this problem. I 
> ran the tests on local environment and took a thread dump after it got stuck. 
> {noformat}
> Full thread dump Java HotSpot(TM) 64-Bit Server VM (24.80-b11 mixed mode):
> "InactivityMonitor Async Task: 
> java.util.concurrent.ThreadPoolExecutor$Worker@2c040428[State = -1, empty 
> queue]" daemon prio=5 tid=0x7fe90d89e000 nid=0x8827 waiting on condition 
> [0x000117b74000]
>java.lang.Thread.State: TIMED_WAITING (parking)
>   at sun.misc.Unsafe.park(Native Method)
>   - parking to wait for  <0x00078166f0b8> (a 
> java.util.concurrent.SynchronousQueue$TransferStack)
>   at 
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:359)
>   at java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:942)
>   at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
>   at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
>   at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>   at java.lang.Thread.run(Thread.java:745)
> "InactivityMonitor Async Task: 
> java.util.concurrent.ThreadPoolExecutor$Worker@182a483f[State = -1, empty 
> queue]" daemon prio=5 tid=0x7fe90d801000 nid=0x585f waiting on condition 
> [0x00011786b000]
>java.lang.Thread.State: TIMED_WAITING (parking)
>   at sun.misc.Unsafe.park(Native Method)
>   - parking to wait for  <0x00078166f0b8> (a 
> java.util.concurrent.SynchronousQueue$TransferStack)
>   at 
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:359)
>   at java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:942)
>   at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
>   at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
>   at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>   at java.lang.Thread.run(Thread.java:745)
> "ActiveMQ Transport: tcp:///127.0.0.1:56883" daemon prio=5 
> tid=0x7fe90c83e800 nid=0x8403 runnable [0x0001196ab000]
>java.lang.Thread.State: RUNNABLE
>   at java.net.SocketInputStream.socketRead0(Native Method)
>   at java.net.SocketInputStream.read(SocketInputStream.java:152)
>   at java.net.SocketInputStream.read(SocketInputStream.java:122)
>   at 
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport$2.fill(TcpTransport.java:576)
>   at 
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport$2.read(TcpTransport.java:561)
>   at java.io.DataInputStream.readInt(DataInputStream.java:387)
>   at 
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:269)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:227)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
>   at java.lang.Thread.run(Thread.java:745)
> "ActiveMQ Transport: tcp://localhost/127.0.0.1:61616" prio=5 
> tid=0x7fe90b81e800 nid=0x8003 runnable [0x0001194a5000]
>java.lang.Thread.State: RUNNABLE
>   at java.net.SocketInputStream.socketRead0(Native Method)
>   at java.net.SocketInputStream.read(SocketInputStream.java:152)
>   at java.net.SocketInputStream.read(SocketInputStream.java:122)
>   at 
> org.apache.activemq.transport.tcp.TcpBuf

[jira] [Updated] (HIVE-14463) hcatalog server extensions test cases getting stuck

[Hari Sankar Sivarama Subramaniyan (JIRA)]

 [ 
https://issues.apache.org/jira/browse/HIVE-14463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Hari Sankar Sivarama Subramaniyan updated HIVE-14463:
-
Attachment: HIVE-14463.1.patch

> hcatalog server extensions test cases getting stuck
> ---
>
> Key: HIVE-14463
> URL: https://issues.apache.org/jira/browse/HIVE-14463
> Project: Hive
>  Issue Type: Bug
>Affects Versions: 2.1.0
>Reporter: Rajat Khandelwal
>Assignee: Hari Sankar Sivarama Subramaniyan
> Attachments: HIVE-14463.1.patch
>
>
> The module is getting stuck in tests and not coming out for as long as 2 
> days. 
> Specifically, TestMsgBusConnection is the test case which has this problem. I 
> ran the tests on local environment and took a thread dump after it got stuck. 
> {noformat}
> Full thread dump Java HotSpot(TM) 64-Bit Server VM (24.80-b11 mixed mode):
> "InactivityMonitor Async Task: 
> java.util.concurrent.ThreadPoolExecutor$Worker@2c040428[State = -1, empty 
> queue]" daemon prio=5 tid=0x7fe90d89e000 nid=0x8827 waiting on condition 
> [0x000117b74000]
>java.lang.Thread.State: TIMED_WAITING (parking)
>   at sun.misc.Unsafe.park(Native Method)
>   - parking to wait for  <0x00078166f0b8> (a 
> java.util.concurrent.SynchronousQueue$TransferStack)
>   at 
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:359)
>   at java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:942)
>   at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
>   at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
>   at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>   at java.lang.Thread.run(Thread.java:745)
> "InactivityMonitor Async Task: 
> java.util.concurrent.ThreadPoolExecutor$Worker@182a483f[State = -1, empty 
> queue]" daemon prio=5 tid=0x7fe90d801000 nid=0x585f waiting on condition 
> [0x00011786b000]
>java.lang.Thread.State: TIMED_WAITING (parking)
>   at sun.misc.Unsafe.park(Native Method)
>   - parking to wait for  <0x00078166f0b8> (a 
> java.util.concurrent.SynchronousQueue$TransferStack)
>   at 
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:359)
>   at java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:942)
>   at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
>   at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
>   at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>   at java.lang.Thread.run(Thread.java:745)
> "ActiveMQ Transport: tcp:///127.0.0.1:56883" daemon prio=5 
> tid=0x7fe90c83e800 nid=0x8403 runnable [0x0001196ab000]
>java.lang.Thread.State: RUNNABLE
>   at java.net.SocketInputStream.socketRead0(Native Method)
>   at java.net.SocketInputStream.read(SocketInputStream.java:152)
>   at java.net.SocketInputStream.read(SocketInputStream.java:122)
>   at 
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport$2.fill(TcpTransport.java:576)
>   at 
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport$2.read(TcpTransport.java:561)
>   at java.io.DataInputStream.readInt(DataInputStream.java:387)
>   at 
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:269)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:227)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
>   at java.lang.Thread.run(Thread.java:745)
> "ActiveMQ Transport: tcp://localhost/127.0.0.1:61616" prio=5 
> tid=0x7fe90b81e800 nid=0x8003 runnable [0x0001194a5000]
>java.lang.Thread.State: RUNNABLE
>   at java.net.SocketInputStream.socketRead0(Native Method)
>   at java.net.SocketInputStream.read(SocketInputStream.java:152)
>   at java.net.SocketInputStream.read(SocketInputStream.java:122)
>   at 
> org.apache.activemq.transport.tcp.TcpBufferedI

[jira] [Updated] (HIVE-14463) hcatalog server extensions test cases getting stuck

[Hari Sankar Sivarama Subramaniyan (JIRA)]

 [ 
https://issues.apache.org/jira/browse/HIVE-14463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Hari Sankar Sivarama Subramaniyan updated HIVE-14463:
-
Attachment: HIVE-14463.1.patch

cc [~ashutoshc] for review.

> hcatalog server extensions test cases getting stuck
> ---
>
> Key: HIVE-14463
> URL: https://issues.apache.org/jira/browse/HIVE-14463
> Project: Hive
>  Issue Type: Bug
>Affects Versions: 2.1.0
>Reporter: Rajat Khandelwal
>Assignee: Hari Sankar Sivarama Subramaniyan
> Attachments: HIVE-14463.1.patch
>
>
> The module is getting stuck in tests and not coming out for as long as 2 
> days. 
> Specifically, TestMsgBusConnection is the test case which has this problem. I 
> ran the tests on local environment and took a thread dump after it got stuck. 
> {noformat}
> Full thread dump Java HotSpot(TM) 64-Bit Server VM (24.80-b11 mixed mode):
> "InactivityMonitor Async Task: 
> java.util.concurrent.ThreadPoolExecutor$Worker@2c040428[State = -1, empty 
> queue]" daemon prio=5 tid=0x7fe90d89e000 nid=0x8827 waiting on condition 
> [0x000117b74000]
>java.lang.Thread.State: TIMED_WAITING (parking)
>   at sun.misc.Unsafe.park(Native Method)
>   - parking to wait for  <0x00078166f0b8> (a 
> java.util.concurrent.SynchronousQueue$TransferStack)
>   at 
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:359)
>   at java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:942)
>   at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
>   at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
>   at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>   at java.lang.Thread.run(Thread.java:745)
> "InactivityMonitor Async Task: 
> java.util.concurrent.ThreadPoolExecutor$Worker@182a483f[State = -1, empty 
> queue]" daemon prio=5 tid=0x7fe90d801000 nid=0x585f waiting on condition 
> [0x00011786b000]
>java.lang.Thread.State: TIMED_WAITING (parking)
>   at sun.misc.Unsafe.park(Native Method)
>   - parking to wait for  <0x00078166f0b8> (a 
> java.util.concurrent.SynchronousQueue$TransferStack)
>   at 
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:359)
>   at java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:942)
>   at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
>   at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
>   at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>   at java.lang.Thread.run(Thread.java:745)
> "ActiveMQ Transport: tcp:///127.0.0.1:56883" daemon prio=5 
> tid=0x7fe90c83e800 nid=0x8403 runnable [0x0001196ab000]
>java.lang.Thread.State: RUNNABLE
>   at java.net.SocketInputStream.socketRead0(Native Method)
>   at java.net.SocketInputStream.read(SocketInputStream.java:152)
>   at java.net.SocketInputStream.read(SocketInputStream.java:122)
>   at 
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport$2.fill(TcpTransport.java:576)
>   at 
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport$2.read(TcpTransport.java:561)
>   at java.io.DataInputStream.readInt(DataInputStream.java:387)
>   at 
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:269)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:227)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
>   at java.lang.Thread.run(Thread.java:745)
> "ActiveMQ Transport: tcp://localhost/127.0.0.1:61616" prio=5 
> tid=0x7fe90b81e800 nid=0x8003 runnable [0x0001194a5000]
>java.lang.Thread.State: RUNNABLE
>   at java.net.SocketInputStream.socketRead0(Native Method)
>   at java.net.SocketInputStream.read(SocketInputStream.java:152)
>   at java.net.SocketInputStream.read(SocketInputStream.java:122)
>   at 
> org.apache.active

[jira] [Updated] (HIVE-14463) hcatalog server extensions test cases getting stuck

[Hari Sankar Sivarama Subramaniyan (JIRA)]

 [ 
https://issues.apache.org/jira/browse/HIVE-14463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Hari Sankar Sivarama Subramaniyan updated HIVE-14463:
-
Attachment: (was: HIVE-14463.1.patch)

> hcatalog server extensions test cases getting stuck
> ---
>
> Key: HIVE-14463
> URL: https://issues.apache.org/jira/browse/HIVE-14463
> Project: Hive
>  Issue Type: Bug
>Affects Versions: 2.1.0
>Reporter: Rajat Khandelwal
>Assignee: Hari Sankar Sivarama Subramaniyan
> Attachments: HIVE-14463.1.patch
>
>
> The module is getting stuck in tests and not coming out for as long as 2 
> days. 
> Specifically, TestMsgBusConnection is the test case which has this problem. I 
> ran the tests on local environment and took a thread dump after it got stuck. 
> {noformat}
> Full thread dump Java HotSpot(TM) 64-Bit Server VM (24.80-b11 mixed mode):
> "InactivityMonitor Async Task: 
> java.util.concurrent.ThreadPoolExecutor$Worker@2c040428[State = -1, empty 
> queue]" daemon prio=5 tid=0x7fe90d89e000 nid=0x8827 waiting on condition 
> [0x000117b74000]
>java.lang.Thread.State: TIMED_WAITING (parking)
>   at sun.misc.Unsafe.park(Native Method)
>   - parking to wait for  <0x00078166f0b8> (a 
> java.util.concurrent.SynchronousQueue$TransferStack)
>   at 
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:359)
>   at java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:942)
>   at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
>   at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
>   at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>   at java.lang.Thread.run(Thread.java:745)
> "InactivityMonitor Async Task: 
> java.util.concurrent.ThreadPoolExecutor$Worker@182a483f[State = -1, empty 
> queue]" daemon prio=5 tid=0x7fe90d801000 nid=0x585f waiting on condition 
> [0x00011786b000]
>java.lang.Thread.State: TIMED_WAITING (parking)
>   at sun.misc.Unsafe.park(Native Method)
>   - parking to wait for  <0x00078166f0b8> (a 
> java.util.concurrent.SynchronousQueue$TransferStack)
>   at 
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460)
>   at 
> java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:359)
>   at java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:942)
>   at 
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
>   at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
>   at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>   at java.lang.Thread.run(Thread.java:745)
> "ActiveMQ Transport: tcp:///127.0.0.1:56883" daemon prio=5 
> tid=0x7fe90c83e800 nid=0x8403 runnable [0x0001196ab000]
>java.lang.Thread.State: RUNNABLE
>   at java.net.SocketInputStream.socketRead0(Native Method)
>   at java.net.SocketInputStream.read(SocketInputStream.java:152)
>   at java.net.SocketInputStream.read(SocketInputStream.java:122)
>   at 
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport$2.fill(TcpTransport.java:576)
>   at 
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport$2.read(TcpTransport.java:561)
>   at java.io.DataInputStream.readInt(DataInputStream.java:387)
>   at 
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:269)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:227)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219)
>   at 
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
>   at java.lang.Thread.run(Thread.java:745)
> "ActiveMQ Transport: tcp://localhost/127.0.0.1:61616" prio=5 
> tid=0x7fe90b81e800 nid=0x8003 runnable [0x0001194a5000]
>java.lang.Thread.State: RUNNABLE
>   at java.net.SocketInputStream.socketRead0(Native Method)
>   at java.net.SocketInputStream.read(SocketInputStream.java:152)
>   at java.net.SocketInputStream.read(SocketInputStream.java:122)
>   at 
> org.apache.activemq.transport.tcp.T