for(Iterator i = deliveries.values().iterator(); i.hasNext(); ) { SingleReceiverDelivery d = (SingleReceiverDelivery)i.next(); if (!d.isSelectorAccepted()) { try { d.cancel(); } catch(Throwable t) { log.error("Failed to cancel delivery " + d, t); } } }
   protected void disconnect()   {      boolean removed = channel.remove(this);            if (removed)      {         disconnected = true;         if (trace) { log.trace(this + " removed from the channel"); }      }   }