@ Override public void shutdown ( ) { enqueuer = new DisruptorEnqueuer ( ) { final AtomicBoolean logged = new AtomicBoolean ( false ) ; @ Override public void enqueue ( Entry entry ) { if ( ! logged . getAndSet ( true ) ) { logger . log ( Level . INFO , "Attempted to enqueue entry after Disruptor shutdown." ) ; } } } ; disruptor . shutdown ( ) ; }
Shuts down the underlying disruptor .