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

Class CommunicationGroup

java.lang.Object

tools.refinery.interpreter.rete.network.communication.CommunicationGroup

All Implemented Interfaces:

Comparable<CommunicationGroup>

Direct Known Subclasses:

RecursiveCommunicationGroup, SingletonCommunicationGroup, TimelyCommunicationGroup

public abstract class CommunicationGroup
extends Object
implements Comparable<CommunicationGroup>

A communication group represents a set of nodes in the communication graph that form a strongly connected component.

Since:

1.6

Field Summary

Fields

Modifier and Type	Field	Description
protected int	identifier	May be changed during bumping in invalid reference CommunicationTracker.registerDependency
boolean	isEnqueued	Marker for the CommunicationTracker
protected final Node	representative
protected final CommunicationTracker	tracker
static final String	UNSUPPORTED_MESSAGE_KIND

Constructor Summary

Constructors

Constructor	Description
CommunicationGroup(CommunicationTracker tracker, Node representative, int identifier)

Method Summary

Modifier and Type	Method	Description
int	compareTo(CommunicationGroup that)
abstract void	deliverMessages()
boolean	equals(Object obj)
abstract Map<MessageSelector,Collection<Mailbox>>	getMailboxes()
Node	getRepresentative()
int	hashCode()
abstract boolean	isEmpty()
abstract boolean	isRecursive()
abstract void	notifyHasMessage(Mailbox mailbox, MessageSelector kind)
abstract void	notifyLostAllMessages(Mailbox mailbox, MessageSelector kind)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

UNSUPPORTED_MESSAGE_KIND

public static final String UNSUPPORTED_MESSAGE_KIND

See Also:

• Constant Field Values

isEnqueued

public boolean isEnqueued

Marker for the CommunicationTracker

representative

protected final Node representative

identifier

protected int identifier

May be changed during bumping in

invalid reference

CommunicationTracker.registerDependency

tracker

protected final CommunicationTracker tracker

Since:

1.7

Constructor Details

CommunicationGroup

public CommunicationGroup(CommunicationTracker tracker,
 Node representative,
 int identifier)

Since:

1.7

Method Details

deliverMessages

public abstract void deliverMessages()

getRepresentative

public Node getRepresentative()

isEmpty

public abstract boolean isEmpty()

notifyLostAllMessages

public abstract void notifyLostAllMessages(Mailbox mailbox,
 MessageSelector kind)

Since:

2.0

notifyHasMessage

public abstract void notifyHasMessage(Mailbox mailbox,
 MessageSelector kind)

Since:

2.0

getMailboxes

public abstract Map<MessageSelector,Collection<Mailbox>> getMailboxes()

isRecursive

public abstract boolean isRecursive()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

compareTo

public int compareTo(CommunicationGroup that)

Specified by:

compareTo in interface Comparable<CommunicationGroup>