de.huxhorn.lilith.engine.impl.eventproducer

Class MessageBasedEventProducer<T extends java.io.Serializable>

java.lang.Object

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

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

All Implemented Interfaces:

EventProducer<T>

Direct Known Subclasses:

AccessEventProtobufMessageBasedEventProducer, LilithJsonMessageLoggingEventProducer, LilithXmlMessageLoggingEventProducer, LoggingEventProtobufMessageBasedEventProducer

public class MessageBasedEventProducer<T extends java.io.Serializable>
extends AbstractEventProducer<T>

Constructor Summary

Constructors

Constructor and Description
MessageBasedEventProducer(SourceIdentifier sourceIdentifier, de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<T>> eventQueue, SourceIdentifierUpdater<T> sourceIdentifierUpdater, de.huxhorn.sulky.codec.Decoder<T> decoder, java.io.InputStream inputStream, boolean requiresHeartbeat)

Method Summary

Modifier and Type	Method and Description
void	close()
void	start()

Methods inherited from class de.huxhorn.lilith.engine.impl.eventproducer.AbstractEventProducer

addEvent, getEventQueue, getSourceIdentifier

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageBasedEventProducer

public MessageBasedEventProducer(SourceIdentifier sourceIdentifier,
                                 de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<T>> eventQueue,
                                 SourceIdentifierUpdater<T> sourceIdentifierUpdater,
                                 de.huxhorn.sulky.codec.Decoder<T> decoder,
                                 java.io.InputStream inputStream,
                                 boolean requiresHeartbeat)

Method Detail

start

public void start()

close

public void close()