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();
        }
    }
Stop the service