Fixes #370

* Fixes #370

Author: amykang2020

mq/main/mq-broker/broker-core/src/main/java/com/sun/messaging/jmq/jmsserver/service/imq/JMSServiceImpl.java

@@ -2638,6 +2638,8 @@ public Packet getNextConsumerPacket(ConsumerUID cuid, long timeout)
 
                 // add an event listener to wake us up when the consumer is busy
                 Object lock = c.addEventListener(this,EventType.BUSY_STATE_CHANGED, null);
+                try {
+
                 while (!c.isBusy() || stopped) {
                     try {
                         // wait until the consumer is not busy
@@ -2697,6 +2699,10 @@ public Packet getNextConsumerPacket(ConsumerUID cuid, long timeout)
 			}
                     } catch (Exception ex) {}
                 // remove the event listener since we arent sure if we will care
+                //c.removeEventListener(lock);
+            } //while
+
+            } finally { 
                 c.removeEventListener(lock);
             }
             //if (stopped) return null;