mam.transaction
Class MessageWaiter

java.lang.Object
  |
  +--java.lang.Thread
        |
        +--mam.transaction.MessageWaiter

public class MessageWaiter

extends Thread

Constructor Summary

MessageWaiter(String identifier, Collection originalMessages, Collection sentMessages, boolean exitAfterQuota)

MessageWaiter(String identifier, Collection originalMessages, Collection sentMessages, long timeOut, long updatePeriod, boolean exitAfterQuota)

Method Summary
synchronized void	addListener(MessageWaiterListener newListener)
protected synchronized void	addResponse(AgentMessage newResponse)
boolean	evaluateMessage(AgentMessage incomingMessage)
protected void	finished()
synchronized Collection	getAllResponses()
boolean	getDone()
boolean	getExitAfterQuota()
Date	getExpirationDate()
Serializable	getIdentifier()
protected Collection	getListeners()
synchronized Collection	getOriginalMessages()
Collection	getRecentResponses()
synchronized Collection	getSentMessages()
long	getUpdatePeriod()
protected void	invalidateRecentResponses()
protected boolean	isExpired()
boolean	isMissingResponses()
protected synchronized void	notifyListeners()
void	run()
void	setExitAfterQuota(boolean exitAfterQuota)
protected void	setIdentifier(Serializable identifier)
protected synchronized void	setTimeOut(long timeOut)
synchronized void	setUpdatePeriod(long updatePeriod)
void	signalDone()
protected void	updateQuota()

Methods inherited from class java.lang.Thread

currentThread, yield, sleep, sleep, start, stop, stop, interrupt, interrupted, isInterrupted, destroy, isAlive, suspend, resume, setPriority, getPriority, setName, getName, getThreadGroup, activeCount, enumerate, countStackFrames, join, join, join, dumpStack, setDaemon, isDaemon, checkAccess, toString, getContextClassLoader, setContextClassLoader

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_TIME_OUT

public final static long DEFAULT_TIME_OUT

public final static long DEFAULT_UPDATE_PERIOD

static Category Log

private Collection m_allResponses

private boolean m_done

private boolean m_exitAfterQuota

private Date m_expirationDate

private Serializable m_identifier

private Collection m_listeners

private Collection m_originalMessages

private Collection m_recentResponses

private Map m_sentMessageIds

private Collection m_sentMessages

private long m_updatePeriod

private boolean m_valid

public MessageWaiter(String identifier, Collection originalMessages, Collection sentMessages, boolean exitAfterQuota)

public MessageWaiter(String identifier, Collection originalMessages, Collection sentMessages, long timeOut, long updatePeriod, boolean exitAfterQuota)

public synchronized void addListener(MessageWaiterListener newListener)

protected synchronized void addResponse(AgentMessage newResponse)

public boolean evaluateMessage(AgentMessage incomingMessage)

protected void finished()

public synchronized Collection getAllResponses()

public boolean getDone()

public boolean getExitAfterQuota()

public Date getExpirationDate()

public Serializable getIdentifier()

protected Collection getListeners()

public synchronized Collection getOriginalMessages()

public Collection getRecentResponses()

public synchronized Collection getSentMessages()

public long getUpdatePeriod()

protected void invalidateRecentResponses()

protected boolean isExpired()

public boolean isMissingResponses()

protected synchronized void notifyListeners()

public void run()

public void setExitAfterQuota(boolean exitAfterQuota)

protected void setIdentifier(Serializable identifier)

protected synchronized void setTimeOut(long timeOut)

public synchronized void setUpdatePeriod(long updatePeriod)

public void signalDone()

protected void updateQuota()