Class ActiveMQSessionExecutor

java.lang.Object

org.apache.activemq.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 Summary

Modifier and Type	Method	Description
protected void	clearMessagesInProgress()
boolean	hasUncomsumedMessages()
boolean	isEmpty()
boolean	iterate()
void	wakeup()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

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