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

Class TimelyIndexerListenerProxy

java.lang.Object

tools.refinery.interpreter.rete.network.communication.timely.TimelyIndexerListenerProxy

All Implemented Interfaces:

IndexerListener

public class TimelyIndexerListenerProxy
extends Object
implements IndexerListener

A timely proxy for another IndexerListener, which performs some preprocessing on the differential timestamps before passing it on to the real recipient.

These proxies are used on edges leading into ProductionNodes. Because ProductionNodes never ask back the indexer for its contents, there is no need to also apply the proxy on that direction.

Since:

2.3

Field Summary

Fields

Modifier and Type	Field	Description
protected final TimestampTransformation	preprocessor
protected final IndexerListener	wrapped

Constructor Summary

Constructors

Constructor	Description
TimelyIndexerListenerProxy(IndexerListener wrapped, TimestampTransformation preprocessor)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object obj)
Node	getOwner()
IndexerListener	getWrappedIndexerListener()
int	hashCode()
void	notifyIndexerUpdate(Direction direction, Tuple updateElement, Tuple signature, boolean change, Timestamp timestamp)	Notifies recipient that the indexer has just received an update.
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

preprocessor

protected final TimestampTransformation preprocessor

wrapped

protected final IndexerListener wrapped

Constructor Details

TimelyIndexerListenerProxy

public TimelyIndexerListenerProxy(IndexerListener wrapped,
 TimestampTransformation preprocessor)

Method Details

getWrappedIndexerListener

public IndexerListener getWrappedIndexerListener()

getOwner

public Node getOwner()

Specified by:

getOwner in interface IndexerListener

notifyIndexerUpdate

public void notifyIndexerUpdate(Direction direction,
 Tuple updateElement,
 Tuple signature,
 boolean change,
 Timestamp timestamp)

Description copied from interface: IndexerListener

Notifies recipient that the indexer has just received an update. Contract: indexer already reflects the updated state.

Specified by:

notifyIndexerUpdate in interface IndexerListener

Parameters:

direction - the direction of the update.

updateElement - the tuple that was updated.

signature - the signature of the tuple according to the indexer's mask.

change - whether this was the first inserted / last revoked update element with this particular signature.

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object