private final boolean handleBlockedWrite(ByteBuffer buffer,DistributionMessage msg) throws ConnectionException {
  if (!addToQueue(buffer,msg,true)) {
    return false;
  }
 else {
    startNioPusher();
    return true;
  }
}

private final boolean handleBlockedWrite ( ByteBuffer buffer , DistributionMessage msg ) throws ConnectionException { if ( ! addToQueue ( buffer , msg , true ) ) { return false ; } else { startNioPusher ( ) ; return true ; } }
return true if it was able to handle a block write of the given buffer . return false if it is still the caller is still responsible for writing it .
