Hi Rob,

Many thanks for your reply.  I've attached the stack-trace as an attachment.

Cheers,
David

Rob Davies wrote:
Hi David,

Your application should be i/o bound with a pre-fetch of 0 (effectively pul every message from the broker) - so something else is going on
Could you send a full stack trace ?

thanks,

Rob
On Dec 20, 2007, at 6:55 AM, David Sitsky wrote:

Hi,

I have simplistically speaking, an application using ActiveMQ 5 which has a queue called work-items.

A master JVM process puts work items onto the queue (this process also runs the embedded JMS broker), and external worker JVM processes read these items using receive() with a timeout of 2 seconds.

I have 4 quad-cores machines running this application, one runs the master program as described, and the other three quad-core machines each runs a worker JVM process, all connected with gigabit ethernet, all machines are running Vista and Java 1.6.

I have 4 separate threads within each worker JVM processing data, each thread with two connections to the broker (one for sending data, one for receiving data) which at the time seemed to give the best results. Each connection has their own associated session object to avoid any "contention".

I am using a prefetch size of 0, as have found this gives the best performance in this application, as each work item's payload can have an unpredictable amount of processing time. Data is sent and received using transactions, and the messages are non-persistent.

Using JMX, I often see the queue size can easily grow to around 10,000 - 20,000 elements, which is as expected, but often, I see the worker threads sitting waiting for messages to be dispatched to them (verified using thread dumps). I also see the master process is consuming a lot of CPU, which perhaps explains why it is unable to keep up.

I've read various documents on the wiki, and have tried a lot of different settings, but it seems that the broker is unable to deliver these messages fast enough to the consumers, or something else is holding it back.

Here are some relevant thread snapshots when the broker is grinding... if anybody has some ideas on what I might be doing wrong, I'd love some suggestions. I have gotten carried away with creating too many connections?

I am a bit worried by PooledTaskRunner iterating over this large number of messages often...

"ActiveMQ Transport: tcp:///192.168.222.75:49197" daemon prio=4 RUNNABLE
at org.apache.activemq.broker.region.RegionBroker.getBrokerService(RegionBroker.java:625) at org.apache.activemq.broker.BrokerFilter.getBrokerService(BrokerFilter.java:245) at org.apache.activemq.broker.BrokerFilter.getBrokerService(BrokerFilter.java:245) at org.apache.activemq.broker.BrokerFilter.getBrokerService(BrokerFilter.java:245) at org.apache.activemq.broker.MutableBrokerFilter.getBrokerService(MutableBrokerFilter.java:261) at org.apache.activemq.broker.ConnectionContext.isSlave(ConnectionContext.java:265) at org.apache.activemq.broker.region.AbstractSubscription.isSlave(AbstractSubscription.java:118) at org.apache.activemq.broker.region.PrefetchSubscription.isFull(PrefetchSubscription.java:361) at org.apache.activemq.broker.region.PrefetchSubscription.dispatchMatched(PrefetchSubscription.java:452) at org.apache.activemq.broker.region.PrefetchSubscription.pullMessage(PrefetchSubscription.java:90) at org.apache.activemq.broker.region.AbstractRegion.messagePull(AbstractRegion.java:348) at org.apache.activemq.broker.region.RegionBroker.messagePull(RegionBroker.java:434) at org.apache.activemq.broker.BrokerFilter.messagePull(BrokerFilter.java:77) at org.apache.activemq.broker.BrokerFilter.messagePull(BrokerFilter.java:77) at org.apache.activemq.broker.BrokerFilter.messagePull(BrokerFilter.java:77) at org.apache.activemq.broker.MutableBrokerFilter.messagePull(MutableBrokerFilter.java:245) at org.apache.activemq.broker.TransportConnection.processMessagePull(TransportConnection.java:444)
    at org.apache.activemq.command.MessagePull.visit(MessagePull.java:43)
at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:280) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:177) at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67) at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:134) at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:150) at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:185) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
    at java.lang.Thread.run(Unknown Source)

"ActiveMQ Task" daemon prio=5 RUNNABLE
at org.apache.activemq.broker.region.PrefetchSubscription.isFull(PrefetchSubscription.java:361) at org.apache.activemq.broker.region.PrefetchSubscription.dispatchMatched(PrefetchSubscription.java:452) at org.apache.activemq.broker.region.PrefetchSubscription.add(PrefetchSubscription.java:141) at org.apache.activemq.broker.region.policy.RoundRobinDispatchPolicy.dispatch(RoundRobinDispatchPolicy.java:70) at org.apache.activemq.broker.region.Queue.doDispatch(Queue.java:1059) at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:1072)
    at org.apache.activemq.broker.region.Queue.iterate(Queue.java:945)
at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:118) at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:42) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
    at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.74:49196" daemon prio=4 BLOCKED
at org.apache.activemq.broker.region.Queue.doMessageSend(Queue.java:449)
    at org.apache.activemq.broker.region.Queue.send(Queue.java:441)
at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:328) at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:402) at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:224) at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:125) at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:95) at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:135) at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:433) at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:623) at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:280) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:177) at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67) at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:134) at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:150) at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:185) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
    at java.lang.Thread.run(Unknown Source)


--
Cheers,
David

Nuix Pty Ltd
Suite 79, 89 Jones St, Ultimo NSW 2007, Australia    Ph: +61 2 9280 0699
Web: http://www.nuix.com                            Fax: +61 2 9212 6902

"ActiveMQ Transport: tcp:///192.168.222.75:49193" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.74:49197" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.73:49205" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"main" prio=5 RUNNABLE

"ActiveMQ Transport: tcp:///192.168.222.74:49195" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.75:49199" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.73:49209" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"Finalizer" daemon prio=8 WAITING
        at java.lang.Object.wait(Native Method)
        at java.lang.ref.ReferenceQueue.remove(Unknown Source)
        at java.lang.ref.ReferenceQueue.remove(Unknown Source)
        at java.lang.ref.Finalizer$FinalizerThread.run(Unknown Source)

"VMTransport" daemon prio=5 TIMED_WAITING
        at sun.misc.Unsafe.park(Native Method)
        at java.util.concurrent.locks.LockSupport.parkNanos(Unknown Source)
        at 
java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(Unknown Source)
        at java.util.concurrent.SynchronousQueue$TransferStack.transfer(Unknown 
Source)
        at java.util.concurrent.SynchronousQueue.poll(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor.getTask(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.75:49197" daemon prio=4 RUNNABLE
        at 
org.apache.activemq.broker.region.RegionBroker.getBrokerService(RegionBroker.java:625)
        at 
org.apache.activemq.broker.BrokerFilter.getBrokerService(BrokerFilter.java:245)
        at 
org.apache.activemq.broker.BrokerFilter.getBrokerService(BrokerFilter.java:245)
        at 
org.apache.activemq.broker.BrokerFilter.getBrokerService(BrokerFilter.java:245)
        at 
org.apache.activemq.broker.MutableBrokerFilter.getBrokerService(MutableBrokerFilter.java:261)
        at 
org.apache.activemq.broker.ConnectionContext.isSlave(ConnectionContext.java:265)
        at 
org.apache.activemq.broker.region.AbstractSubscription.isSlave(AbstractSubscription.java:118)
        at 
org.apache.activemq.broker.region.PrefetchSubscription.isFull(PrefetchSubscription.java:361)
        at 
org.apache.activemq.broker.region.PrefetchSubscription.dispatchMatched(PrefetchSubscription.java:452)
        at 
org.apache.activemq.broker.region.PrefetchSubscription.pullMessage(PrefetchSubscription.java:90)
        at 
org.apache.activemq.broker.region.AbstractRegion.messagePull(AbstractRegion.java:348)
        at 
org.apache.activemq.broker.region.RegionBroker.messagePull(RegionBroker.java:434)
        at 
org.apache.activemq.broker.BrokerFilter.messagePull(BrokerFilter.java:77)
        at 
org.apache.activemq.broker.BrokerFilter.messagePull(BrokerFilter.java:77)
        at 
org.apache.activemq.broker.BrokerFilter.messagePull(BrokerFilter.java:77)
        at 
org.apache.activemq.broker.MutableBrokerFilter.messagePull(MutableBrokerFilter.java:245)
        at 
org.apache.activemq.broker.TransportConnection.processMessagePull(TransportConnection.java:444)
        at org.apache.activemq.command.MessagePull.visit(MessagePull.java:43)
        at 
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:280)
        at 
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:177)
        at 
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
        at 
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:134)
        at 
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:150)
        at 
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:185)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.74:49194" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"RMI RenewClean-[192.168.222.76:49191]" daemon prio=5 TIMED_WAITING
        at java.lang.Object.wait(Native Method)
        at java.lang.ref.ReferenceQueue.remove(Unknown Source)
        at 
sun.rmi.transport.DGCClient$EndpointEntry$RenewCleanThread.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"RMI Scheduler(0)" daemon prio=5 TIMED_WAITING
        at sun.misc.Unsafe.park(Native Method)
        at java.util.concurrent.locks.LockSupport.parkNanos(Unknown Source)
        at 
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(Unknown
 Source)
        at java.util.concurrent.DelayQueue.take(Unknown Source)
        at 
java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(Unknown 
Source)
        at 
java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(Unknown 
Source)
        at java.util.concurrent.ThreadPoolExecutor.getTask(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.73:49208" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.74:49199" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"Thread-4" daemon prio=6 WAITING
        at java.lang.Object.wait(Native Method)
        at java.lang.Object.wait(Object.java:485)
        at java.util.prefs.AbstractPreferences$EventDispatchThread.run(Unknown 
Source)

"Java2D Disposer" daemon prio=10 WAITING
        at java.lang.Object.wait(Native Method)
        at java.lang.ref.ReferenceQueue.remove(Unknown Source)
        at java.lang.ref.ReferenceQueue.remove(Unknown Source)
        at sun.java2d.Disposer.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.74:49200" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.75:49196" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Scheduler" daemon prio=5 TIMED_WAITING
        at java.lang.Object.wait(Native Method)
        at java.util.TimerThread.mainLoop(Unknown Source)
        at java.util.TimerThread.run(Unknown Source)

"TimerQueue" daemon prio=5 TIMED_WAITING
        at java.lang.Object.wait(Native Method)
        at javax.swing.TimerQueue.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.73:49206" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.75:49194" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport Server: 
tcp://localhost:27616?wireFormat.maxInactivityDuration=0&wireFormat.tcpNoDelayEnabled=true"
 daemon prio=9 RUNNABLE
        at java.net.PlainSocketImpl.socketAccept(Native Method)
        at java.net.PlainSocketImpl.accept(Unknown Source)
        at java.net.ServerSocket.implAccept(Unknown Source)
        at java.net.ServerSocket.accept(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpTransportServer.run(TcpTransportServer.java:197)
        at java.lang.Thread.run(Unknown Source)

"derby.antiGC" daemon prio=1 WAITING
        at java.lang.Object.wait(Native Method)
        at java.lang.Object.wait(Object.java:485)
        at org.apache.derby.impl.services.monitor.AntiGC.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.73:49203" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.73:49204" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"AWT-EventQueue-0" prio=6 RUNNABLE
        at java.lang.Thread.dumpThreads(Native Method)
        at java.lang.Thread.getAllStackTraces(Unknown Source)
        at gX.actionPerformed(SourceFile:16)
        at javax.swing.JComponent$ActionStandin.actionPerformed(Unknown Source)
        at javax.swing.SwingUtilities.notifyAction(Unknown Source)
        at javax.swing.JComponent.processKeyBinding(Unknown Source)
        at javax.swing.KeyboardManager.fireBinding(Unknown Source)
        at javax.swing.KeyboardManager.fireKeyboardAction(Unknown Source)
        at javax.swing.JComponent.processKeyBindingsForAllComponents(Unknown 
Source)
        at javax.swing.SwingUtilities.processKeyBindings(Unknown Source)
        at javax.swing.UIManager$2.postProcessKeyEvent(Unknown Source)
        at java.awt.DefaultKeyboardFocusManager.dispatchKeyEvent(Unknown Source)
        at java.awt.DefaultKeyboardFocusManager.preDispatchKeyEvent(Unknown 
Source)
        at java.awt.DefaultKeyboardFocusManager.typeAheadAssertions(Unknown 
Source)
        at java.awt.DefaultKeyboardFocusManager.dispatchEvent(Unknown Source)
        at java.awt.Component.dispatchEventImpl(Unknown Source)
        at java.awt.Container.dispatchEventImpl(Unknown Source)
        at java.awt.Window.dispatchEventImpl(Unknown Source)
        at java.awt.Component.dispatchEvent(Unknown Source)
        at java.awt.EventQueue.dispatchEvent(Unknown Source)
        at java.awt.EventDispatchThread.pumpOneEventForFilters(Unknown Source)
        at java.awt.EventDispatchThread.pumpEventsForFilter(Unknown Source)
        at java.awt.EventDispatchThread.pumpEventsForHierarchy(Unknown Source)
        at java.awt.EventDispatchThread.pumpEvents(Unknown Source)
        at java.awt.EventDispatchThread.pumpEvents(Unknown Source)
        at java.awt.EventDispatchThread.run(Unknown Source)

"Timer-0" daemon prio=5 TIMED_WAITING
        at java.lang.Object.wait(Native Method)
        at java.util.TimerThread.mainLoop(Unknown Source)
        at java.util.TimerThread.run(Unknown Source)

"JmDNS.SocketListener" daemon prio=5 RUNNABLE
        at java.net.PlainDatagramSocketImpl.receive0(Native Method)
        at java.net.PlainDatagramSocketImpl.receive(Unknown Source)
        at java.net.DatagramSocket.receive(Unknown Source)
        at javax.jmdns.JmDNS$SocketListener.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"Attach Listener" daemon prio=5 RUNNABLE

"Signal Dispatcher" daemon prio=9 RUNNABLE

"GC Daemon" daemon prio=2 TIMED_WAITING
        at java.lang.Object.wait(Native Method)
        at sun.misc.GC$Daemon.run(Unknown Source)

"AWT-Shutdown" prio=5 WAITING
        at java.lang.Object.wait(Native Method)
        at java.lang.Object.wait(Object.java:485)
        at sun.awt.AWTAutoShutdown.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"SwingWorker-pool-1-thread-3" prio=5 WAITING
        at java.lang.Object.wait(Native Method)
        at java.lang.Object.wait(Object.java:485)
        at 
org.apache.activemq.MessageDispatchChannel.dequeue(MessageDispatchChannel.java:75)
        at 
org.apache.activemq.ActiveMQMessageConsumer.dequeue(ActiveMQMessageConsumer.java:404)
        at 
org.apache.activemq.ActiveMQMessageConsumer.receive(ActiveMQMessageConsumer.java:513)
        at kx.a(SourceFile:600)
        at lr.doInBackground(SourceFile:105)
        at javax.swing.SwingWorker$1.call(Unknown Source)
        at java.util.concurrent.FutureTask$Sync.innerRun(Unknown Source)
        at java.util.concurrent.FutureTask.run(Unknown Source)
        at javax.swing.SwingWorker.run(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown 
Source)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Session Task" prio=7 WAITING
        at sun.misc.Unsafe.park(Native Method)
        at java.util.concurrent.locks.LockSupport.park(Unknown Source)
        at 
java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(Unknown Source)
        at java.util.concurrent.SynchronousQueue$TransferStack.transfer(Unknown 
Source)
        at java.util.concurrent.SynchronousQueue.take(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor.getTask(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"VMTransport" daemon prio=5 TIMED_WAITING
        at sun.misc.Unsafe.park(Native Method)
        at java.util.concurrent.locks.LockSupport.parkNanos(Unknown Source)
        at 
java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(Unknown Source)
        at java.util.concurrent.SynchronousQueue$TransferStack.transfer(Unknown 
Source)
        at java.util.concurrent.SynchronousQueue.poll(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor.getTask(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"VMTransport" daemon prio=5 TIMED_WAITING
        at sun.misc.Unsafe.park(Native Method)
        at java.util.concurrent.locks.LockSupport.parkNanos(Unknown Source)
        at 
java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(Unknown Source)
        at java.util.concurrent.SynchronousQueue$TransferStack.transfer(Unknown 
Source)
        at java.util.concurrent.SynchronousQueue.poll(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor.getTask(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.73:49210" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"derby.rawStoreDaemon" daemon prio=5 TIMED_WAITING
        at java.lang.Object.wait(Native Method)
        at org.apache.derby.impl.services.daemon.BasicDaemon.rest(Unknown 
Source)
        at org.apache.derby.impl.services.daemon.BasicDaemon.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"RMI TCP Accept-0" daemon prio=5 RUNNABLE
        at java.net.PlainSocketImpl.socketAccept(Native Method)
        at java.net.PlainSocketImpl.accept(Unknown Source)
        at java.net.ServerSocket.implAccept(Unknown Source)
        at java.net.ServerSocket.accept(Unknown Source)
        at 
sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(Unknown Source)
        at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport Status Monitor: 
tcp://WORKER0:27616?wireFormat.maxInactivityDuration=0&wireFormat.tcpNoDelayEnabled=true"
 daemon prio=9 TIMED_WAITING
        at java.lang.Thread.sleep(Native Method)
        at 
org.apache.activemq.broker.TransportStatusDetector.run(TransportStatusDetector.java:102)
        at java.lang.Thread.run(Unknown Source)

"Swing-Shell" daemon prio=6 WAITING
        at sun.misc.Unsafe.park(Native Method)
        at java.util.concurrent.locks.LockSupport.park(Unknown Source)
        at 
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(Unknown
 Source)
        at java.util.concurrent.LinkedBlockingQueue.take(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor.getTask(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
        at sun.awt.shell.Win32ShellFolder2$ComTaskExecutor$2.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.74:49198" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.75:49195" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"AWT-Windows" daemon prio=6 RUNNABLE
        at sun.awt.windows.WToolkit.eventLoop(Native Method)
        at sun.awt.windows.WToolkit.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"RMI Reaper" prio=5 WAITING
        at java.lang.Object.wait(Native Method)
        at java.lang.ref.ReferenceQueue.remove(Unknown Source)
        at java.lang.ref.ReferenceQueue.remove(Unknown Source)
        at sun.rmi.transport.ObjectTable$Reaper.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"Reference Handler" daemon prio=10 WAITING
        at java.lang.Object.wait(Native Method)
        at java.lang.Object.wait(Object.java:485)
        at java.lang.ref.Reference$ReferenceHandler.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.75:49198" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.74:49193" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.75:49200" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"RMI TCP Accept-1099" daemon prio=5 RUNNABLE
        at java.net.PlainSocketImpl.socketAccept(Native Method)
        at java.net.PlainSocketImpl.accept(Unknown Source)
        at java.net.ServerSocket.implAccept(Unknown Source)
        at java.net.ServerSocket.accept(Unknown Source)
        at 
sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(Unknown Source)
        at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Task" daemon prio=5 TIMED_WAITING
        at sun.misc.Unsafe.park(Native Method)
        at java.util.concurrent.locks.LockSupport.parkNanos(Unknown Source)
        at 
java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(Unknown Source)
        at java.util.concurrent.SynchronousQueue$TransferStack.transfer(Unknown 
Source)
        at java.util.concurrent.SynchronousQueue.poll(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor.getTask(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Task" daemon prio=5 RUNNABLE
        at 
org.apache.activemq.broker.region.PrefetchSubscription.isFull(PrefetchSubscription.java:361)
        at 
org.apache.activemq.broker.region.PrefetchSubscription.dispatchMatched(PrefetchSubscription.java:452)
        at 
org.apache.activemq.broker.region.PrefetchSubscription.add(PrefetchSubscription.java:141)
        at 
org.apache.activemq.broker.region.policy.RoundRobinDispatchPolicy.dispatch(RoundRobinDispatchPolicy.java:70)
        at org.apache.activemq.broker.region.Queue.doDispatch(Queue.java:1059)
        at 
org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:1072)
        at org.apache.activemq.broker.region.Queue.iterate(Queue.java:945)
        at 
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:118)
        at 
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:42)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown 
Source)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.74:49196" daemon prio=4 BLOCKED
        at org.apache.activemq.broker.region.Queue.doMessageSend(Queue.java:449)
        at org.apache.activemq.broker.region.Queue.send(Queue.java:441)
        at 
org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:328)
        at 
org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:402)
        at 
org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:224)
        at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:125)
        at 
org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:95)
        at 
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:135)
        at 
org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:433)
        at 
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:623)
        at 
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:280)
        at 
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:177)
        at 
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
        at 
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:134)
        at 
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:150)
        at 
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:185)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.222.73:49207" daemon prio=4 RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(Unknown Source)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at 
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
        at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
        at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
        at java.lang.Thread.run(Unknown Source)

"Timer-1" daemon prio=5 WAITING
        at java.lang.Object.wait(Native Method)
        at java.lang.Object.wait(Object.java:485)
        at java.util.TimerThread.mainLoop(Unknown Source)
        at java.util.TimerThread.run(Unknown Source)

Reply via email to