code: private void checkFull() {
      if (!full && messages.size() >= maxQueueSize) {
        full = true;
        log.debug(String.format("%s - Connection to %s is full", this, context.target()));
      }
    }
docs: Checks whether the connection is full.