de.huxhorn.lilith.engine

Interface EventProducer<T extends java.io.Serializable>

All Known Implementing Classes:

AbstractEventProducer, AccessEventProtobufMessageBasedEventProducer, JulXmlStreamLoggingEventProducer, LilithJsonMessageLoggingEventProducer, LilithXmlMessageLoggingEventProducer, LilithXmlStreamLoggingEventProducer, LoggingEventProtobufMessageBasedEventProducer, MessageBasedEventProducer, SerializableEventProducer, ZeroDelimitedEventProducer

public interface EventProducer<T extends java.io.Serializable>

The responsibility of EventProducers is the creation of events from some kind of input, e.g. an InputStream. Those events are wrapped into an EventWrapper and appended to the event queue of the producer.

Method Summary

Modifier and Type	Method and Description
void	close()
de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<T>>	getEventQueue()
SourceIdentifier	getSourceIdentifier()
void	start()

Method Detail

getSourceIdentifier

SourceIdentifier getSourceIdentifier()

Returns:

the source of the events.

getEventQueue

de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<T>> getEventQueue()

Returns:

the event queue that this producer appends events to.

start

void start()

close

void close()