@ PostConstruct public void start ( ) { threadFactory = Executors . defaultThreadFactory ( ) ; disruptor = new Disruptor <> ( Registration . FACTORY , ringSize , threadFactory , ProducerType . MULTI , new BlockingWaitStrategy ( ) ) ; disruptor . handleEventsWith ( new ContainerEventHandler ( ) ) ; ringBuffer = disruptor . start ( ) ; }
Set up the disruptor service to have a single consumer which aggregates the data .