mam.messaging
Class MessageQueue

public class MessageQueue

implements MessageReceiver, Serializable

A utility class for the mam system. Implements a simple queuing system for incoming messages - does not support any kind of priorities, etc. Intended usage: MessageReceivers allow messages to accumulate while doing whatever. receiveMessage simply adds each incoming message to the MessageQueue When ready to process messages, simply get an Enumeration of all currently waiting messages and process them in order.

protected MamId m_mamId

protected Vector m_messages

public MessageQueue()

public synchronized AgentMessage dequeueFirstMessage()

public synchronized AgentMessage dequeueLastMessage()

public synchronized AgentMessage dequeueMessage()

public synchronized AgentMessage dequeueMessageFromSource(MamId desiredSource)

public synchronized AgentMessage dequeueMessageOfType(String desiredMessageType)

public synchronized void enqueueMessage(AgentMessage incomingMessage)

public MamId getMamId()

public boolean hasWaitingMessages()

public boolean requiresPersistence()

public int size()