public void shutdown() {
        /**
         * Probably we don't need this method in practice
         */
        if (initLocker.get() && shutdownLocker.compareAndSet(false, true)) {
            // do shutdown
            log.info("Shutting down transport...");

            // we just sending out ShutdownRequestMessage
            //transport.sendMessage(new ShutdownRequestMessage());
            transport.shutdown();

            executor.shutdown();

        }
    }
public void shutdown() {
        
        if (initLocker.get() && shutdownLocker.compareAndSet(false, true)) {
            
            log.info("Shutting down transport...");

            
            
            transport.shutdown();

            executor.shutdown();

        }
    }
public void shutdown ( ) { /**
         * Probably we don't need this method in practice
         */ if ( initLocker . get ( ) && shutdownLocker . compareAndSet ( false , true ) ) { // do shutdown log . info ( "Shutting down transport..." ) ; // we just sending out ShutdownRequestMessage //transport.sendMessage(new ShutdownRequestMessage()); transport . shutdown ( ) ; executor . shutdown ( ) ; } }
This method initiates shutdown sequence for this instance.

PLEASE NOTE: This method is blocking for first caller only
This method initiates shutdown sequence for this instance .