@ Override public void stop ( ) { if ( connectionOption . isPresent ( ) ) { try { if ( startConnection ) connectionOption . get ( ) . close ( ) ; } catch ( JMSException e ) { throw new JmsException ( "Unable to stop " , e ) ; } connectionOption = Optional . empty ( ) ; sessionOption = Optional . empty ( ) ; producers . clear ( ) ; consumers . clear ( ) ; destinations . clear ( ) ; } }
Stop the service