Package com.inductiveautomation.eventstream.gateway.sources

Class GatewayMessageHandler

java.lang.Object

com.inductiveautomation.eventstream.gateway.sources.GatewayMessageHandler

All Implemented Interfaces:

EventStreamHandler

public class GatewayMessageHandler
extends Object
implements EventStreamHandler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	GatewayMessageHandler.Dispatcher

Nested classes/interfaces inherited from interface com.inductiveautomation.eventstream.gateway.api.EventStreamHandler

EventStreamHandler.Descriptor, EventStreamHandler.Factory

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ID

Constructor Summary

Constructors

Constructor	Description
GatewayMessageHandler(GatewayMessageHandler.Dispatcher dispatcher, GatewayMessageHandlerConfig config)

Method Summary

Modifier and Type	Method	Description
static EventStreamHandler.Factory	createFactory(MessageDispatchManager dispatchManager)
void	handle(List<EventPayload> events, boolean testMode)	Called when a batch of events is ready to be processed.
void	onStartup(EventStreamExpressionFactory expressionFactory)	Called when Event Stream first starts and before the EventStreamHandler starts receiving events through EventStreamHandler.handle(java.util.List<com.inductiveautomation.eventstream.EventPayload>, boolean).

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.inductiveautomation.eventstream.gateway.api.EventStreamHandler

onShutdown

Field Details

ID

public static final String ID

See Also:

• Constant Field Values

Constructor Details

GatewayMessageHandler

public GatewayMessageHandler(GatewayMessageHandler.Dispatcher dispatcher,
 GatewayMessageHandlerConfig config)

Method Details

createFactory

public static EventStreamHandler.Factory createFactory(MessageDispatchManager dispatchManager)

onStartup

public void onStartup(EventStreamExpressionFactory expressionFactory)
               throws Exception

Description copied from interface: EventStreamHandler

Called when Event Stream first starts and before the EventStreamHandler starts receiving events through EventStreamHandler.handle(java.util.List<com.inductiveautomation.eventstream.EventPayload>, boolean).

Specified by:

onStartup in interface EventStreamHandler

Parameters:

expressionFactory - Factory for creating EventStreamExpression from expression fields.

Throws:

Exception - An exception here will prevent the Event Stream for subscribing to source. This is useful if something fails in onStartup() that EventStreamHandler.handle(java.util.List<com.inductiveautomation.eventstream.EventPayload>, boolean) requires to successfully process events.

handle

public void handle(List<EventPayload> events,
 boolean testMode)
            throws Exception

Description copied from interface: EventStreamHandler

Called when a batch of events is ready to be processed. It's important that an exception is throw on errors encountered during handling of events. If an exception is encountered, it should be expected that the method may be called again in the future with the same events. This is determined by the failure strategy specified by the Event Stream configuration.

Specified by:

handle in interface EventStreamHandler

Parameters:

events - List of events to process.

testMode - True, if Event Stream is running in test mode. If running in testMode, expressions should be evaluated with no other side effects.

Throws:

Exception - Exception thrown during processing.