Class TopicConsumer

    • Field Detail

      • subscriberId

        protected int subscriberId
      • queueName

        protected java.lang.String queueName
    • Constructor Detail

      • TopicConsumer

        protected TopicConsumer​(SessionContext ctx,
                                TopicImpl topic,
                                java.lang.String selector,
                                boolean noLocal)
                         throws java.lang.Exception
        Throws:
        java.lang.Exception
    • Method Detail

      • getQueueName

        public java.lang.String getQueueName()
      • setAutoCommit

        protected void setAutoCommit​(boolean autoCommit)
      • close

        protected void close()
                      throws java.lang.Exception
        Overrides:
        close in class Consumer
        Throws:
        java.lang.Exception
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object