de.huxhorn.lilith.engine.impl.eventproducer

Class AbstractEventProducer<T extends java.io.Serializable>

java.lang.Object

de.huxhorn.lilith.engine.impl.eventproducer.AbstractEventProducer<T>

All Implemented Interfaces:

EventProducer<T>

Direct Known Subclasses:

JulXmlStreamLoggingEventProducer, LilithXmlStreamLoggingEventProducer, MessageBasedEventProducer, SerializableEventProducer, ZeroDelimitedEventProducer

public abstract class AbstractEventProducer<T extends java.io.Serializable>
extends java.lang.Object
implements EventProducer<T>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractEventProducer(SourceIdentifier sourceIdentifier, de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<T>> eventQueue, SourceIdentifierUpdater<T> sourceIdentifierUpdater)

Method Summary

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface de.huxhorn.lilith.engine.EventProducer

close, start

Constructor Detail

AbstractEventProducer

protected AbstractEventProducer(SourceIdentifier sourceIdentifier,
                                de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<T>> eventQueue,
                                SourceIdentifierUpdater<T> sourceIdentifierUpdater)

Method Detail

getSourceIdentifier

public SourceIdentifier getSourceIdentifier()

Specified by:

getSourceIdentifier in interface EventProducer<T extends java.io.Serializable>

Returns:

the source of the events.

getEventQueue

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

Specified by:

getEventQueue in interface EventProducer<T extends java.io.Serializable>

Returns:

the event queue that this producer appends events to.

addEvent

protected void addEvent(T event)