Package org.jgrapes.core.internal

Class EventProcessor

java.lang.Object

org.jgrapes.core.internal.EventProcessor

All Implemented Interfaces:

Runnable, Components.IdInfoProvider

public class EventProcessor
extends Object
implements Runnable

This class provides the default implementation of an EventPipeline.

Field Summary

Fields

Modifier and Type	Field	Description
protected static final ThreadLocal<EventBase<?>>	newEventsParent
protected final Queue<EventChannelsTuple>	queue

Method Summary

Modifier and Type	Method	Description
<T extends Event<?>> T	add(T event, Channel... channels)
void	awaitExhaustion()
ExecutorService	executorService()
default Class<?>	idScope()	All pipelines use the same id scope to make them uniquely identifiable by their number.
void	merge(org.jgrapes.core.internal.InternalEventPipeline other)
void	run()
String	toString()
protected org.jgrapes.core.internal.ComponentTree	tree()	Gets the component tree.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jgrapes.core.Components.IdInfoProvider

idObject

Field Details

newEventsParent

protected static final ThreadLocal<EventBase<?>> newEventsParent

queue

protected final Queue<EventChannelsTuple> queue

Method Details

tree

protected org.jgrapes.core.internal.ComponentTree tree()

Gets the component tree.

Returns:

the component tree

add

public <T extends Event<?>> T add(T event,
 Channel... channels)

merge

public void merge(org.jgrapes.core.internal.InternalEventPipeline other)

run

public void run()

Specified by:

run in interface Runnable

executorService

public ExecutorService executorService()

awaitExhaustion

public void awaitExhaustion()
                     throws InterruptedException

Throws:

InterruptedException

toString

public String toString()

Overrides:

toString in class Object

idScope

default Class<?> idScope()

All pipelines use the same id scope to make them uniquely identifiable by their number.

Specified by:

idScope in interface Components.IdInfoProvider

Returns:

the scope