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

Class BehaviorChangingMailbox

java.lang.Object

tools.refinery.interpreter.rete.network.mailbox.timeless.BehaviorChangingMailbox

All Implemented Interfaces:

Clearable, IGroupable, FallThroughCapableMailbox, Mailbox

public class BehaviorChangingMailbox
extends Object
implements FallThroughCapableMailbox

This mailbox changes its behavior based on the position of its Receiver in the network topology. It either behaves as a DefaultMailbox or as an UpdateSplittingMailbox. The decision is made by the CommunicationTracker, see TimelessCommunicationTracker.postProcessNode(Node) for more details.

Field Summary

Fields

Modifier and Type	Field	Description
protected final ReteContainer	container
protected boolean	fallThrough
protected CommunicationGroup	group
protected final Receiver	receiver
protected boolean	split
protected AdaptableMailbox	wrapped

Constructor Summary

Constructors

Constructor	Description
BehaviorChangingMailbox(Receiver receiver, ReteContainer container)

Method Summary

Modifier and Type	Method	Description
void	clear()
void	deliverAll(MessageSelector kind)	Delivers all messages according to the given selector from this mailbox.
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.
boolean	isFallThrough()
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.
void	setFallThrough(boolean fallThrough)
void	setSplitFlag(boolean splitValue)
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

fallThrough

protected boolean fallThrough

split

protected boolean split

wrapped

protected AdaptableMailbox wrapped

receiver

protected final Receiver receiver

container

protected final ReteContainer container

group

protected CommunicationGroup group

Constructor Details

BehaviorChangingMailbox

public BehaviorChangingMailbox(Receiver receiver,
 ReteContainer container)

Method Details

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 kind)

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:

kind - the message selector

toString

public String toString()

Overrides:

toString in class Object

setSplitFlag

public void setSplitFlag(boolean splitValue)

isEmpty

public boolean isEmpty()

Description copied from interface: Mailbox

Returns true if this mailbox is empty.

Specified by:

isEmpty in interface Mailbox

Returns:

clear

public void clear()

Specified by:

clear in interface Clearable

getReceiver

public Receiver getReceiver()

Description copied from interface: Mailbox

Returns the Receiver of this mailbox.

Specified by:

getReceiver in interface Mailbox

Returns:

the receiver

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

isFallThrough

public boolean isFallThrough()

Specified by:

isFallThrough in interface FallThroughCapableMailbox

setFallThrough

public void setFallThrough(boolean fallThrough)

Specified by:

setFallThrough in interface FallThroughCapableMailbox