Class ActiveMQSessionExecutor

  • All Implemented Interfaces:
    Task

    public class ActiveMQSessionExecutor
    extends Object
    implements Task
    A utility class used by the Session for dispatching messages asynchronously to consumers
    See Also:
    Session
    • Method Detail

      • wakeup

        public void wakeup()
      • hasUncomsumedMessages

        public boolean hasUncomsumedMessages()
      • clearMessagesInProgress

        protected void clearMessagesInProgress()
      • isEmpty

        public boolean isEmpty()
      • iterate

        public boolean iterate()
        Specified by:
        iterate in interface Task