com.fluxtion.compiler.generation.targets

Class InMemoryEventProcessor

java.lang.Object

com.fluxtion.compiler.generation.targets.InMemoryEventProcessor

All Implemented Interfaces:

com.fluxtion.runtime.EventProcessor, com.fluxtion.runtime.lifecycle.BatchHandler, com.fluxtion.runtime.lifecycle.Lifecycle, com.fluxtion.runtime.StaticEventProcessor

public class InMemoryEventProcessor
extends Object
implements com.fluxtion.runtime.EventProcessor, com.fluxtion.runtime.StaticEventProcessor, com.fluxtion.runtime.lifecycle.Lifecycle, com.fluxtion.runtime.lifecycle.BatchHandler

Field Summary

Fields inherited from interface com.fluxtion.runtime.StaticEventProcessor

NULL_EVENTHANDLER

Constructor Summary

Constructors

Constructor and Description
InMemoryEventProcessor()

Method Summary

Modifier and Type	Method and Description
void	batchEnd()
void	batchPause()
Field	getFieldByName(String name)
<T> T	getNodeById(String id)
void	init()
void	onEvent(Object event)
void	onEventInternal(Object event)
void	tearDown()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.fluxtion.runtime.StaticEventProcessor

addSink, addSink, addSink, addSink, getStreamed, onEvent, onEvent, onEvent, onEvent, onEvent, onEvent, onEvent, publishDoubleSignal, publishIntSignal, publishLongSignal, publishSignal, publishSignal, publishSignal, publishSignal, publishSignal, removeSink, setAuditLogLevel

Constructor Detail

InMemoryEventProcessor

public InMemoryEventProcessor()

Method Detail

onEvent

public void onEvent(Object event)

Specified by:

onEvent in interface com.fluxtion.runtime.StaticEventProcessor

onEventInternal

public void onEventInternal(Object event)

batchPause

public void batchPause()

Specified by:

batchPause in interface com.fluxtion.runtime.lifecycle.BatchHandler

batchEnd

public void batchEnd()

Specified by:

batchEnd in interface com.fluxtion.runtime.lifecycle.BatchHandler

init

public void init()

Specified by:

init in interface com.fluxtion.runtime.lifecycle.Lifecycle

tearDown

public void tearDown()

Specified by:

tearDown in interface com.fluxtion.runtime.lifecycle.Lifecycle

getFieldByName

public Field getFieldByName(String name)

getNodeById

public <T> T getNodeById(String id)
                  throws NoSuchFieldException

Specified by:

getNodeById in interface com.fluxtion.runtime.StaticEventProcessor

Throws:

NoSuchFieldException