Package com.inductiveautomation.eventstream.gateway.sources

Class FileSource

java.lang.Object

com.inductiveautomation.eventstream.gateway.sources.FileSource

All Implemented Interfaces:

EventStreamSource

public class FileSource
extends Object
implements EventStreamSource

This source reads events from a file and forwards them to the event stream.

Nested Class Summary

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

EventStreamSource.Factory, EventStreamSource.Subscriber

Constructor Summary

Constructors

Constructor	Description
FileSource(String filePath, int batchSize)

Method Summary

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

FileSource

public FileSource(String filePath,
 int batchSize)

Method Details

createFactory

public static EventStreamSource.Factory createFactory()

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