listener.onMessage(m.getReceivedObject());
listener.onMessage(m);
   public void run()   {      if (log.isTraceEnabled()) { log.trace("listener thread started"); }            while(true)      {         try         {            if (log.isTraceEnabled()) { log.trace("blocking to take a message"); }            JBossMessage m = (JBossMessage)messages.take();				            listener.onMessage(m.getReceivedObject());            if (log.isTraceEnabled()) { log.trace("message successfully handled by listener"); }            delivered(m);         }         catch(InterruptedException e)         {            log.debug("message listener thread interrupted, exiting");            return;         }         catch(Throwable t)         {            // TODO - different actions for client error/commuication error            // TODO - try several times and then give up?            log.error(t);         }      }   }