Use disruptor as if it was a queue or stream with consume and push constructs