Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » [javadoc | source]
org.apache.activemq
public class: ActiveMQSessionExecutor [javadoc | source]
java.lang.Object
   org.apache.activemq.ActiveMQSessionExecutor

All Implemented Interfaces:
    Task

A utility class used by the Session for dispatching messages asynchronously to consumers
Constructor:
 ActiveMQSessionExecutor(ActiveMQSession session) 
Method from org.apache.activemq.ActiveMQSessionExecutor Summary:
clear,   clearMessagesInProgress,   close,   dequeueNoWait,   dispatch,   execute,   executeFirst,   getUnconsumedMessages,   hasUncomsumedMessages,   isEmpty,   isRunning,   iterate,   setDispatchedBySessionPool,   start,   stop,   wakeup
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.ActiveMQSessionExecutor Detail:
  void clear() 
 protected  void clearMessagesInProgress() 
  void close() 
 MessageDispatch dequeueNoWait() 
  void dispatch(MessageDispatch message) 
  void execute(MessageDispatch message) throws InterruptedException 
  void executeFirst(MessageDispatch message) 
 List getUnconsumedMessages() 
 public boolean hasUncomsumedMessages() 
 public boolean isEmpty() 
 boolean isRunning() 
 public boolean iterate() 
  void setDispatchedBySessionPool(boolean value) 
 synchronized  void start() 
  void stop() throws JMSException 
 public  void wakeup()