this.messages = new BoundedBuffer(capacity); this.isConnectionConsumer = isCC;
channel = new SynchronousChannel();  isConnectionConsumer = isCC;  closedLock = new Object();
   public MessageCallbackHandler(boolean isCC)   {      this.messages = new BoundedBuffer(capacity);      this.isConnectionConsumer = isCC;   }