public abstract class AbstractUpdateSplittingMailbox<IndexerType extends MessageIndexer,ReceiverType extends Receiver> extends java.lang.Object implements Mailbox
Modifier and Type | Field and Description |
---|---|
protected IndexerType |
antiMonotoneBuffer |
protected IndexerType |
antiMonotoneQueue |
protected ReteContainer |
container |
protected boolean |
deliveringAntiMonotone |
protected boolean |
deliveringMonotone |
protected CommunicationGroup |
group |
protected IndexerType |
monotoneBuffer |
protected IndexerType |
monotoneQueue |
protected ReceiverType |
receiver |
Constructor and Description |
---|
AbstractUpdateSplittingMailbox(ReceiverType receiver,
ReteContainer container,
MessageIndexerFactory<IndexerType> factory) |
Modifier and Type | Method and Description |
---|---|
void |
clear()
Clear all partial matchings stored in memory
|
protected IndexerType |
getActiveAntiMonotoneQueue() |
protected IndexerType |
getActiveMonotoneQueue() |
CommunicationGroup |
getCurrentGroup()
Returns the
CommunicationGroup of the receiver of this mailbox. |
ReceiverType |
getReceiver()
Returns the
Receiver of this mailbox. |
boolean |
isEmpty()
Returns true if this mailbox is empty.
|
void |
setCurrentGroup(CommunicationGroup group)
Sets the
CommunicationGroup that the receiver of this mailbox is associated with. |
protected void |
swapAndClearAntiMonotone() |
protected void |
swapAndClearMonotone() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
deliverAll, postMessage
protected IndexerType extends MessageIndexer monotoneQueue
protected IndexerType extends MessageIndexer antiMonotoneQueue
protected IndexerType extends MessageIndexer monotoneBuffer
protected IndexerType extends MessageIndexer antiMonotoneBuffer
protected boolean deliveringMonotone
protected boolean deliveringAntiMonotone
protected final ReceiverType extends Receiver receiver
protected final ReteContainer container
protected CommunicationGroup group
public AbstractUpdateSplittingMailbox(ReceiverType receiver, ReteContainer container, MessageIndexerFactory<IndexerType> factory)
protected void swapAndClearMonotone()
protected void swapAndClearAntiMonotone()
protected IndexerType getActiveMonotoneQueue()
protected IndexerType getActiveAntiMonotoneQueue()
public ReceiverType getReceiver()
Mailbox
Receiver
of this mailbox.getReceiver
in interface Mailbox
public void clear()
Clearable
public CommunicationGroup getCurrentGroup()
Mailbox
CommunicationGroup
of the receiver of this mailbox.getCurrentGroup
in interface IGroupable
getCurrentGroup
in interface Mailbox
public void setCurrentGroup(CommunicationGroup group)
Mailbox
CommunicationGroup
that the receiver of this mailbox is associated with.setCurrentGroup
in interface IGroupable
setCurrentGroup
in interface Mailbox
group
- the communication group