org.apache.activemq
Class ActiveMQSessionExecutor

java.lang.Object
  extended by org.apache.activemq.ActiveMQSessionExecutor
All Implemented Interfaces:
Task

public class ActiveMQSessionExecutor
extends java.lang.Object
implements Task

A utility class used by the Session for dispatching messages asynchronously to consumers

See Also:
Session

Method Summary
protected  void clearMessagesInProgress()
           
 boolean hasUncomsumedMessages()
           
 boolean isEmpty()
           
 boolean iterate()
           
 void wakeup()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

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


Copyright © 2005-2011 FuseSource, Corp.. All Rights Reserved.