log.warn("Failed to deliver the message to the client, perhaps the client consumer has closed", t);
log.warn("Failed to deliver the message to the client, clearing up connection resources", t);  ConnectionManager mgr = connection.getServerPeer().getConnectionManager();  mgr.unregisterConnection(connection.getRemotingClientSessionId());
   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);               }   }