public abstract class ObjectSource extends BaseNode implements Externalizable
FactHandle
s for an ObjectSink
.
Nodes that propagate FactHandleImpl
extend this class.
ObjectSource
,
DefaultFactHandle
,
Serialized FormModifier and Type | Field and Description |
---|---|
protected long |
declaredMask |
protected long |
inferredMask |
protected ObjectSinkPropagator |
sink
The destination for
FactHandleImpl . |
protected ObjectSource |
source |
associations, id, partitionId, partitionsEnabled, streamMode
Constructor and Description |
---|
ObjectSource() |
Modifier and Type | Method and Description |
---|---|
void |
addObjectSink(ObjectSink objectSink)
Adds the
ObjectSink so that it may receive
FactHandleImpl propagated from this
ObjectSource . |
abstract long |
calculateDeclaredMask(List<String> settableProperties) |
protected void |
doRemove(RuleRemovalContext context,
ReteooBuilder builder,
InternalWorkingMemory[] workingMemories)
Removes the node from teh network.
|
long |
getDeclaredMask() |
protected ObjectTypeNode |
getObjectTypeNode() |
ObjectSource |
getParentObjectSource() |
ObjectSinkPropagator |
getSinkPropagator() |
void |
initDeclaredMask(BuildContext context) |
boolean |
isInUse()
Returns true in case the current node is in use (is referenced by any other node)
|
void |
networkUpdated(UpdateContext updateContext)
A method that is called for all nodes whose network below them
changed, after the change is complete, providing them with an oportunity
for state update
|
void |
readExternal(ObjectInput in) |
void |
removeObjectSink(ObjectSink objectSink)
Removes the
ObjectSink |
void |
resetInferredMask() |
long |
updateMask(long mask) |
abstract void |
updateSink(ObjectSink sink,
PropagationContext context,
InternalWorkingMemory workingMemory) |
void |
writeExternal(ObjectOutput out) |
addAssociation, attach, attach, getAssociations, getId, getPartitionId, hashCode, isStreamMode, registerUnlinkedPaths, remove, removeAssociation, setId, setPartitionId, toString
clone, equals, finalize, getClass, notify, notifyAll, wait, wait, wait
getType
protected ObjectSinkPropagator sink
FactHandleImpl
.protected ObjectSource source
protected long declaredMask
protected long inferredMask
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal
in interface Externalizable
readExternal
in class BaseNode
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
writeExternal
in interface Externalizable
writeExternal
in class BaseNode
IOException
public ObjectSource getParentObjectSource()
public void initDeclaredMask(BuildContext context)
public void resetInferredMask()
public long updateMask(long mask)
public void addObjectSink(ObjectSink objectSink)
ObjectSink
so that it may receive
FactHandleImpl
propagated from this
ObjectSource
.objectSink
- The ObjectSink
to receive propagated
FactHandleImpl
.public void removeObjectSink(ObjectSink objectSink)
ObjectSink
objectSink
- The ObjectSink
to removepublic abstract void updateSink(ObjectSink sink, PropagationContext context, InternalWorkingMemory workingMemory)
public void networkUpdated(UpdateContext updateContext)
BaseNode
networkUpdated
in class BaseNode
public ObjectSinkPropagator getSinkPropagator()
public boolean isInUse()
BaseNode
protected void doRemove(RuleRemovalContext context, ReteooBuilder builder, InternalWorkingMemory[] workingMemories)
BaseNode
ObjectSource
or TupleSource
protected ObjectTypeNode getObjectTypeNode()
public long getDeclaredMask()
Copyright © 2001-2015 JBoss by Red Hat. All Rights Reserved.