code: public static <T> QueueBasedSubscriber<T> subscriber(final QueueFactory<T> factory, final Counter counter, final int maxConcurrency) {
  
          return new QueueBasedSubscriber<>(
                  factory, counter, maxConcurrency);
      }
docs: Create a QueueBasedSubscriber, backed by a Queue that will be created with the provided QueueFactory
  
  @param factory QueueFactory
  @param counter Counter for tracking connections to the queue and data volumes
  @param maxConcurrency Maximum number of subscriptions
  @return QueueBasedSubscriber