qbit-ext/jms/src/main/java/io/advantageous/qbit/jms/JmsService.java
@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();
        }
    }
@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();
        }
    }
@ 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
Stop the service