Package tools.refinery.interpreter.rete.network.mailbox.timely

Class TimelyMailbox

java.lang.Object

tools.refinery.interpreter.rete.network.mailbox.timely.TimelyMailbox

All Implemented Interfaces:

Clearable, IGroupable, Mailbox

public class TimelyMailbox
extends Object
implements Mailbox

Field Summary

Fields

Modifier and Type	Field	Description
protected final ReteContainer	container
protected boolean	fallThrough
protected CommunicationGroup	group
protected TreeMap<Timestamp,Map<Tuple,Integer>>	queue
protected final Receiver	receiver

Constructor Summary

Constructors

Constructor	Description
TimelyMailbox(Receiver receiver, ReteContainer container)

Method Summary

Modifier and Type	Method	Description
void	clear()
void	deliverAll(MessageSelector selector)	Delivers all messages according to the given selector from this mailbox.
protected TreeMap<Timestamp,Map<Tuple,Integer>>	getActiveQueue()
CommunicationGroup	getCurrentGroup()	Returns the CommunicationGroup of the receiver of this mailbox.
Receiver	getReceiver()	Returns the Receiver of this mailbox.
boolean	isEmpty()	Returns true if this mailbox is empty.
void	postMessage(Direction direction, Tuple update, Timestamp timestamp)	Posts a new message to this mailbox.
void	setCurrentGroup(CommunicationGroup group)	Sets the CommunicationGroup that the receiver of this mailbox is associated with.
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

queue

protected TreeMap<Timestamp,Map<Tuple,Integer>> queue

receiver

protected final Receiver receiver

container

protected final ReteContainer container

group

protected CommunicationGroup group

fallThrough

protected boolean fallThrough

Constructor Details

TimelyMailbox

public TimelyMailbox(Receiver receiver,
 ReteContainer container)

Method Details

getActiveQueue

protected TreeMap<Timestamp,Map<Tuple,Integer>> getActiveQueue()

isEmpty

public boolean isEmpty()

Description copied from interface: Mailbox

Returns true if this mailbox is empty.

Specified by:

isEmpty in interface Mailbox

Returns:

postMessage

public void postMessage(Direction direction,
 Tuple update,
 Timestamp timestamp)

Description copied from interface: Mailbox

Posts a new message to this mailbox.

Specified by:

postMessage in interface Mailbox

Parameters:

direction - the direction of the update

update - the update element

deliverAll

public void deliverAll(MessageSelector selector)

Description copied from interface: Mailbox

Delivers all messages according to the given selector from this mailbox. The selector can also be null. In this case, no special separation is expected between the messages.

Specified by:

deliverAll in interface Mailbox

Parameters:

selector - the message selector

toString

public String toString()

Overrides:

toString in class Object

getReceiver

public Receiver getReceiver()

Description copied from interface: Mailbox

Returns the Receiver of this mailbox.

Specified by:

getReceiver in interface Mailbox

Returns:

the receiver

clear

public void clear()

Specified by:

clear in interface Clearable

getCurrentGroup

public CommunicationGroup getCurrentGroup()

Description copied from interface: Mailbox

Returns the CommunicationGroup of the receiver of this mailbox.

Specified by:

getCurrentGroup in interface IGroupable

Specified by:

getCurrentGroup in interface Mailbox

Returns:

the communication group

setCurrentGroup

public void setCurrentGroup(CommunicationGroup group)

Description copied from interface: Mailbox

Sets the CommunicationGroup that the receiver of this mailbox is associated with.

Specified by:

setCurrentGroup in interface IGroupable

Specified by:

setCurrentGroup in interface Mailbox

Parameters:

group - the communication group