public static < T > QueueBasedSubscriber < T > subscriber ( final QueueFactory < T > factory , final Counter counter , final int maxConcurrency ) { return new QueueBasedSubscriber <> ( factory , counter , maxConcurrency ) ; }
Create a QueueBasedSubscriber backed by a Queue that will be created with the provided QueueFactory