org.apache.activemq
Class ActiveMQSessionExecutor

java.lang.Object
  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