Package net.thevpc.naru.api.scheduler

Class NaruEvent

java.lang.Object

net.thevpc.naru.api.scheduler.NaruEvent

public class NaruEvent
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TASK_TERMINATED

Constructor Summary

Constructors

Constructor	Description
NaruEvent(long seq, String name, Map<String,Object> payload, long sourceTid, long sourcePid, Instant firedAt, NaruEventTarget target, NaruRetentionPolicy retentionPolicy)
NaruEvent(String name, Map<String,Object> payload, long sourceTid, long sourcePid, Instant firedAt, NaruEventTarget target, NaruRetentionPolicy retentionPolicy)

Method Summary

Modifier and Type	Method	Description
int	consumedCount()
long[]	consumedTids()
Instant	firedAt()
boolean	isConsumedBy(long tid)
boolean	isConsumedTid(long id)
boolean	isVisitedBy(long tid)
boolean	isVisitedTids(long id)
void	markConsumed(long tid)
void	markVisited(long tid)
String	name()
long	nextCheckMillis()
Map<String,Object>	payload()
Object	payload(String key)
NaruRetentionPolicy	retentionPolicy()
long	seq()
boolean	shouldDrop()
long	sourcePid()
long	sourceTid()
NaruEventTarget	target()
String	toString()
int	visitedCount()
long[]	visitedTids()
NaruEvent	withSeq(long newSeq)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

TASK_TERMINATED

public static final String TASK_TERMINATED

See Also:

• Constant Field Values

Constructor Details

NaruEvent

public NaruEvent(long seq,
 String name,
 Map<String,Object> payload,
 long sourceTid,
 long sourcePid,
 Instant firedAt,
 NaruEventTarget target,
 NaruRetentionPolicy retentionPolicy)

NaruEvent

public NaruEvent(String name,
 Map<String,Object> payload,
 long sourceTid,
 long sourcePid,
 Instant firedAt,
 NaruEventTarget target,
 NaruRetentionPolicy retentionPolicy)

Method Details

withSeq

public NaruEvent withSeq(long newSeq)

seq

public long seq()

name

public String name()

payload

public Map<String,Object> payload()

payload

public Object payload(String key)

sourceTid

public long sourceTid()

sourcePid

public long sourcePid()

firedAt

public Instant firedAt()

target

public NaruEventTarget target()

retentionPolicy

public NaruRetentionPolicy retentionPolicy()

markVisited

public void markVisited(long tid)

markConsumed

public void markConsumed(long tid)

isVisitedBy

public boolean isVisitedBy(long tid)

isConsumedBy

public boolean isConsumedBy(long tid)

visitedCount

public int visitedCount()

consumedCount

public int consumedCount()

visitedTids

public long[] visitedTids()

consumedTids

public long[] consumedTids()

isVisitedTids

public boolean isVisitedTids(long id)

isConsumedTid

public boolean isConsumedTid(long id)

shouldDrop

public boolean shouldDrop()

nextCheckMillis

public long nextCheckMillis()

toString

public String toString()

Overrides:

toString in class Object