public class PosetAwareMailbox extends AbstractUpdateSplittingMailbox<GroupBasedMessageIndexer,PosetAwareReceiver>
IPosetComparator
to identify if a pair of
REVOKE - INSERT updates represent a monotone change pair. The mailbox is used by PosetAwareReceiver
s.Modifier and Type | Field and Description |
---|---|
protected TupleMask |
groupMask |
antiMonotoneBuffer, antiMonotoneQueue, container, deliveringAntiMonotone, deliveringMonotone, group, monotoneBuffer, monotoneQueue, receiver
Constructor and Description |
---|
PosetAwareMailbox(PosetAwareReceiver receiver,
ReteContainer container) |
Modifier and Type | Method and Description |
---|---|
void |
deliverAll(MessageKind kind)
Delivers all messages of the given kind from this mailbox.
|
void |
postMessage(Direction direction,
Tuple update)
Posts a new message to this mailbox.
|
java.lang.String |
toString() |
protected java.util.Set<Tuple> |
tryFindCounterPart(Tuple first,
boolean findPositiveCounterPart,
boolean findAllCounterParts) |
clear, getActiveAntiMonotoneQueue, getActiveMonotoneQueue, getCurrentGroup, getReceiver, isEmpty, setCurrentGroup, swapAndClearAntiMonotone, swapAndClearMonotone
protected final TupleMask groupMask
public PosetAwareMailbox(PosetAwareReceiver receiver, ReteContainer container)
public void postMessage(Direction direction, Tuple update)
Mailbox
direction
- the direction of the updateupdate
- the update elementprotected java.util.Set<Tuple> tryFindCounterPart(Tuple first, boolean findPositiveCounterPart, boolean findAllCounterParts)
public void deliverAll(MessageKind kind)
Mailbox
kind
- the message kindpublic java.lang.String toString()
toString
in class java.lang.Object