callbackClient.invoke(this);
connection.getCallbackClient().invoke(this);
   public void run()   {      try      {         if (trace) { log.trace("handing " + this.msg + " over to the remoting layer"); }                  callbackClient.invoke(this);               }      catch(Throwable t)      {         log.warn("Failed to deliver the message to the client, perhaps the client consumer has closed", t);               }   }