Package com.inductiveautomation.eventstream.gateway.sources

Class GatewayEventSource

java.lang.Object

com.inductiveautomation.eventstream.gateway.sources.GatewayEventSource

All Implemented Interfaces:

EventStreamSource

public class GatewayEventSource
extends Object
implements EventStreamSource

Nested Class Summary

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

EventStreamSource.Factory, EventStreamSource.Subscriber

Constructor Summary

Constructors

Constructor	Description
GatewayEventSource(String project, String path, EventStreamEventBus messageBus)

Method Summary

Modifier and Type	Method	Description
static EventStreamSource.Factory	createFactory(EventStreamEventBus messageBus)
void	onShutdown()	Called on EventStreamSource shutdown.
void	onStartup(EventStreamSource.Subscriber subscriber)	Called on Event Stream startup.

Methods inherited from class java.lang.Object

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

Constructor Details

GatewayEventSource

public GatewayEventSource(String project,
 String path,
 EventStreamEventBus messageBus)

Method Details

createFactory

public static EventStreamSource.Factory createFactory(EventStreamEventBus messageBus)

onStartup

public void onStartup(EventStreamSource.Subscriber subscriber)

Description copied from interface: EventStreamSource

Called on Event Stream startup. Events can safely be sent to EventStreamSource.Subscriber.submitEvents(java.util.List<com.inductiveautomation.eventstream.EventPayload>) or EventStreamSource.Subscriber.submitEvent(com.inductiveautomation.eventstream.EventPayload).

Specified by:

onStartup in interface EventStreamSource

onShutdown

public void onShutdown()

Description copied from interface: EventStreamSource

Called on EventStreamSource shutdown. No more events should be sent through EventStreamSource.Subscriber. If events are submitted after, they'll immediately complete with Error result.

Specified by:

onShutdown in interface EventStreamSource