Class Consumer

    • Method Detail

      • isAutoCommit

        protected boolean isAutoCommit()
      • setQueueReceiver

        protected void setQueueReceiver​(QueueReceiver receiver)
      • setSelector

        protected void setSelector​(Selector selector)
      • getSelector

        public Selector getSelector()
      • createReadTransaction

        public QueueTransaction createReadTransaction()
                                               throws java.lang.Exception
        Throws:
        java.lang.Exception
      • createDuplicateTransaction

        public QueueTransaction createDuplicateTransaction()
                                                    throws java.lang.Exception
        Throws:
        java.lang.Exception
      • setMessageListener

        public void setMessageListener​(int clientDispatchId,
                                       int clientListenerId,
                                       MessageProcessor messageProcessor)
      • getClientDispatchId

        public int getClientDispatchId()
      • getClientListenerId

        public int getClientListenerId()
      • removeMessageListener

        public void removeMessageListener()
      • hasListener

        public boolean hasListener()
      • close

        protected void close()
                      throws java.lang.Exception
        Throws:
        java.lang.Exception