Method close

java/jms/src/org/opendds/jms/SessionImpl.java:268–284

()

    }

    public void close() throws JMSException {
        if (closed) return;

        logger.debug("Closing %s", this);

        for (MessageProducer producer: createdProducers) {
            producer.close();
        }

        for (MessageConsumer consumer: createdConsumers) {
            consumer.close();
        }

        executor.shutdown();

        closed = true;
    }

    public void checkClosed() {
        if (closed) throw new IllegalStateException("This Session is closed.");