We have seen some issues with 'SubscriptionBufferOverflowException' when large amounts of events are available for reading. The exceptions them selves then cause additional delays. The idea behind this pull-request is to allow for a more grace full handling of congestion. By using BlockingQueue we slow down the fastest code paths when they get to far ahead.
We have seen some issues with 'SubscriptionBufferOverflowException' when large amounts of events are available for reading. The exceptions them selves then cause additional delays. The idea behind this pull-request is to allow for a more grace full handling of congestion. By using BlockingQueue we slow down the fastest code paths when they get to far ahead.