class LimitedQueueCallback implements LimitQueueCallback {

  @Override
  public void setLimitHandler(final LimitHandler limitHandler) {
    this.limitHandler = Objects.requireNonNull(limitHandler, "limitHandler");
    if (remaining.get() == 0) {
      limitHandler.limitReached();
    }
  }

    LimitedQueueCallback(final int limit);

}