java.nio.channels.ClosedChannelException
        at java.nio.channels.spi.AbstractSelectableChannel.register(AbstractSele
ctableChannel.java:167)
        at org.apache.activemq.transport.nio.SelectorSelection$1.run(SelectorSel
ection.java:44)
        at org.apache.activemq.transport.nio.SelectorWorker.processIoTasks(Selec
torWorker.java:75)
        at org.apache.activemq.transport.nio.SelectorWorker.run(SelectorWorker.j
ava:91)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExec
utor.java:886)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
.java:908)
        at java.lang.Thread.run(Thread.java:662)
java.lang.NullPointerException
        at org.apache.activemq.transport.nio.SelectorSelection$2.run(SelectorSel
ection.java:60)
        at org.apache.activemq.transport.nio.SelectorWorker.processIoTasks(Selec
torWorker.java:75)
        at org.apache.activemq.transport.nio.SelectorWorker.run(SelectorWorker.j
ava:91)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExec
utor.java:886)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
.java:908)
        at java.lang.Thread.run(Thread.java:662)
java.lang.NullPointerException
        at org.apache.activemq.transport.nio.SelectorSelection$4.run(SelectorSel
ection.java:84)
        at org.apache.activemq.transport.nio.SelectorWorker.processIoTasks(Selec
torWorker.java:75)
        at org.apache.activemq.transport.nio.SelectorWorker.run(SelectorWorker.j
ava:91)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExec
utor.java:886)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
.java:908)
        at java.lang.Thread.run(Thread.java:662)

   for (int i=0; i<3; i++) {
            // Check the consumer count rather than the active task count. Reason: if the
            // destination is of type topic, then the transport is only ready to receive
            // messages if at least one consumer exists. This is of not much importance,
            // except for automated tests.
            if (stm.getConsumerCount() > 0) {
                log.info("Started to listen on destination : " + stm.getDestinationJNDIName() +
                    " of type " + JMSUtils.getDestinationTypeAsString(stm.getDestinationType()) +
                    " for service " + stm.getServiceName());
                return;
            }
            try {
                Thread.sleep(1000);
            } catch (InterruptedException ignore) {}
        }