if (!listenerStopping)
if (!stopping)
   public void run()   {      if (log.isTraceEnabled()) { log.trace("listener thread started"); }            try      {               while(true)         {                        if (log.isTraceEnabled()) { log.trace("blocking to take a message"); }                        if (!listenerStopping)            {                              JBossMessage m = getMessage(0);                           preDeliver(m);                  listener.onMessage(m);               if (log.isTraceEnabled()) { log.trace("message successfully handled by listener"); }               postDeliver(m);               }            else            {               break;            }         }           }      catch(InterruptedException e)      {         log.debug("message listener thread interrupted, exiting");               }      catch (JMSException e)      {         log.error("Failed to deliver message", e);      }      finally      {         listening = false;      }   }