Specialized queuing construct that is intended for a two-phase scenario where in the first-phase events need to be streamed to disk until the consumer is ready - View it on GitHub