Class MessageConsumer.Closer

  • Enclosing class:
    MessageConsumer

    class MessageConsumer.Closer
    extends Object
    This class synchronizes the close. Close can't be synchronized with 'this' concurrently during its closure. So we need a second lock.
    • Constructor Detail

      • Closer

        Closer()
    • Method Detail

      • close

        void close()
            throws jakarta.jms.JMSException
        Throws:
        jakarta.jms.JMSException