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

Class TimelyMailboxProxy

java.lang.Object

tools.refinery.interpreter.rete.network.communication.timely.TimelyMailboxProxy

All Implemented Interfaces:

Clearable, IGroupable, Mailbox

public class TimelyMailboxProxy
extends Object
implements Mailbox

A timely proxy for another Mailbox, which performs some preprocessing on the differential timestamps before passing it on to the real recipient.

Since:

2.3

Field Summary

Fields

Modifier and Type	Field	Description
protected final TimestampTransformation	preprocessor
protected final Mailbox	wrapped

Constructor Summary

Constructors

Constructor	Description
TimelyMailboxProxy(Mailbox wrapped, TimestampTransformation preprocessor)

Method Summary

Modifier and Type	Method	Description
void	clear()
void	deliverAll(MessageSelector selector)	Delivers all messages according to the given selector from this mailbox.
boolean	equals(Object obj)
CommunicationGroup	getCurrentGroup()	Returns the CommunicationGroup of the receiver of this mailbox.
Receiver	getReceiver()	Returns the Receiver of this mailbox.
Mailbox	getWrappedMailbox()
int	hashCode()
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, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

preprocessor

protected final TimestampTransformation preprocessor

wrapped

protected final Mailbox wrapped

Constructor Details

TimelyMailboxProxy

public TimelyMailboxProxy(Mailbox wrapped,
 TimestampTransformation preprocessor)

Method Details

getWrappedMailbox

public Mailbox getWrappedMailbox()

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

toString

public String toString()

Overrides:

toString in class Object

clear

public void clear()

Specified by:

clear in interface Clearable

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

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

getReceiver

public Receiver getReceiver()

Description copied from interface: Mailbox

Returns the Receiver of this mailbox.

Specified by:

getReceiver in interface Mailbox

Returns:

the receiver

isEmpty

public boolean isEmpty()

Description copied from interface: Mailbox

Returns true if this mailbox is empty.

Specified by:

isEmpty in interface Mailbox

Returns:

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object