Replace lmax disruptor with QueuedNotificationManager