de.huxhorn.lilith.engine.impl.sourceproducer

Class AbstractServerSocketEventSourceProducer<T extends java.io.Serializable>

java.lang.Object

de.huxhorn.lilith.engine.impl.sourceproducer.AbstractServerSocketEventSourceProducer<T>

All Implemented Interfaces:

EventSourceProducer<T>, java.lang.Runnable

Direct Known Subclasses:

AccessEventProtobufServerSocketEventSourceProducer, JulXmlStreamLoggingServerSocketEventSourceProducer, LilithJsonMessageLoggingServerSocketEventSourceProducer, LilithJsonStreamLoggingServerSocketEventSourceProducer, LilithXmlMessageLoggingServerSocketEventSourceProducer, LilithXmlStreamLoggingServerSocketEventSourceProducer, Log4j2JsonServerSocketEventSourceProducer, Log4j2XmlServerSocketEventSourceProducer, Log4j2YamlServerSocketEventSourceProducer, LoggingEventProtobufServerSocketEventSourceProducer, SerializableServerSocketEventSourceProducer

public abstract class AbstractServerSocketEventSourceProducer<T extends java.io.Serializable>
extends java.lang.Object
implements EventSourceProducer<T>, java.lang.Runnable

Constructor Summary

Constructors

Constructor and Description
AbstractServerSocketEventSourceProducer(int port)

Method Summary

Modifier and Type	Method and Description
protected abstract EventProducer<T>	createProducer(SourceIdentifier id, de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<T>> eventQueue, java.io.InputStream inputStream)
int	getPort()
de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<T>>	getQueue()
SourceManager<T>	getSourceManager()
void	run()
void	setQueue(de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<T>> queue)
void	setSourceManager(SourceManager<T> sourceManager)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractServerSocketEventSourceProducer

public AbstractServerSocketEventSourceProducer(int port)
                                        throws java.io.IOException

Throws:

java.io.IOException

Method Detail

getQueue

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

Specified by:

getQueue in interface EventSourceProducer<T extends java.io.Serializable>

setQueue

public void setQueue(de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<T>> queue)

Specified by:

setQueue in interface EventSourceProducer<T extends java.io.Serializable>

getSourceManager

public SourceManager<T> getSourceManager()

Specified by:

getSourceManager in interface EventSourceProducer<T extends java.io.Serializable>

setSourceManager

public void setSourceManager(SourceManager<T> sourceManager)

Specified by:

setSourceManager in interface EventSourceProducer<T extends java.io.Serializable>

getPort

public int getPort()

run

public void run()

Specified by:

run in interface java.lang.Runnable

createProducer

protected abstract EventProducer<T> createProducer(SourceIdentifier id,
                                                   de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<T>> eventQueue,
                                                   java.io.InputStream inputStream)
                                            throws java.io.IOException

Throws:

java.io.IOException