add disruptor support and add bulk operations for workers