Class AbstractListenerPipeConsumer<T>