Package com.inductiveautomation.eventstream.gateway.sources

Class LastEventSource

java.lang.Object

com.inductiveautomation.eventstream.gateway.sources.LastEventSource

All Implemented Interfaces:

EventStreamSource

public class LastEventSource
extends Object
implements EventStreamSource

This source emits the last event that was emitted by a source. Used by Test Mode.

Nested Class Summary

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

EventStreamSource.Factory, EventStreamSource.Subscriber

Constructor Summary

Constructors

Constructor	Description
LastEventSource(LastSourceEventCache lastSourceEventCache, EventStreamKey key)

Method Summary

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

LastEventSource

public LastEventSource(LastSourceEventCache lastSourceEventCache,
 EventStreamKey key)

Method Details

createFactory

public static EventStreamSource.Factory createFactory(LastSourceEventCache lastSourceEventCache)

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