View Source Extreme.ListenerWithBackPressure (extreme v1.1.0-rc4)

The same as Extreme.Listener but uses event_producer functionality which applies backpressure on live events as well.

The way it works is that there's intermediate process which turns off subscription when max_buffer is reached and creates new subscription when all buffered events are processed.