public static < T > QueueBasedSubscriber < T > subscriber ( final Queue < T > q , final Counter counter , final int maxConcurrency ) { return new QueueBasedSubscriber <> ( q , counter , maxConcurrency ) ; }
Create a QueueBasedSubscriber backed by the provided Queue