changed stream junction and classes needed for disruptor