this.messages = new BoundedBuffer(capacity); }
this.messages = new BoundedBuffer(capacity); this.isConnectionConsumer = isCC;   }
   public MessageCallbackHandler()   {      this.messages = new BoundedBuffer(capacity);	   }