ds.funnel.node.event

Class EventProcessor<E>

java.lang.Object

ds.funnel.node.task.Task<T>

ds.funnel.node.task.ScheduledTask<java.lang.Void>

ds.funnel.node.event.EventProcessor<E>

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

PeerGroupQueue

public class EventProcessor<E>
extends ScheduledTask<java.lang.Void>

Field Summary

Fields inherited from class ds.funnel.node.task.Task

AUTOSTART, IGNORENULL, RUNONCE

Constructor Summary

Constructors

Constructor and Description
EventProcessor(EventHandler<? super E> inHandler)

Method Summary

Modifier and Type	Method and Description
java.util.List<E>	getQueuedEvents()
int	queueEvent(E inEvent)
void	setHandler(EventHandler<? super E> inHandler)

Methods inherited from class ds.funnel.node.task.ScheduledTask

cancel, startTaskAsync, startTaskLater, startTaskTimer

Methods inherited from class ds.funnel.node.task.Task

chainTask, getResult, getResult, getResultNow, isCancelled, run, startTask

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventProcessor

public EventProcessor(EventHandler<? super E> inHandler)

Method Detail

queueEvent

public int queueEvent(E inEvent)

setHandler

public void setHandler(EventHandler<? super E> inHandler)

getQueuedEvents

public java.util.List<E> getQueuedEvents()