Package com.inductiveautomation.eventstream.gateway.sources

Class SuppliedSource

java.lang.Object

com.inductiveautomation.eventstream.gateway.sources.SuppliedSource

All Implemented Interfaces:

EventStreamSource

public class SuppliedSource
extends Object
implements EventStreamSource

Emits only the Object provided by Supplier

Nested Class Summary

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

EventStreamSource.Factory, EventStreamSource.Subscriber

Constructor Summary

Constructors

Constructor	Description
SuppliedSource(EncoderRegistry encoders, SuppliedSourceConfig config)

Method Summary

Modifier and Type	Method	Description
static EventStreamSource.Factory	createFactory(EncoderRegistry encoders)
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

SuppliedSource

public SuppliedSource(EncoderRegistry encoders,
 SuppliedSourceConfig config)

Method Details

createFactory

public static EventStreamSource.Factory createFactory(EncoderRegistry encoders)

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