jm.setSessionDelegate(sessionDelegate);
if (!this.isConnectionConsumer) { jm.setSessionDelegate(sessionDelegate); }
   public void handleCallback(Callback callback) throws HandleCallbackException   {      if (log.isTraceEnabled()) { log.trace("receiving message " + callback.getParameter() + " from the remoting layer"); }      Message m = (Message)callback.getParameter();            try      {			         JBossMessage jm = (JBossMessage)m;	         jm.setSessionDelegate(sessionDelegate);         messages.put(m);         if (log.isTraceEnabled()) { log.trace("message " + m + " queued in the client delivery queue"); }      }      catch(InterruptedException e)      {         String msg = "Interrupted attempt to put message in the delivery buffer";         log.warn(msg);         throw new HandleCallbackException(msg, e);      }   }