public class SerializableServerSocketEventSourceProducer<T extends java.io.Serializable> extends AbstractServerSocketEventSourceProducer<T>
Constructor and Description |
---|
SerializableServerSocketEventSourceProducer(int port,
ConverterRegistry<T> converterRegistry,
SourceIdentifierUpdater<T> sourceIdentifierUpdater) |
Modifier and Type | Method and Description |
---|---|
protected EventProducer<T> |
createProducer(SourceIdentifier id,
de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<T>> eventQueue,
java.io.InputStream inputStream) |
java.lang.String |
toString() |
getPort, getQueue, getSourceManager, run, setQueue, setSourceManager
public SerializableServerSocketEventSourceProducer(int port, ConverterRegistry<T> converterRegistry, SourceIdentifierUpdater<T> sourceIdentifierUpdater) throws java.io.IOException
java.io.IOException
protected EventProducer<T> createProducer(SourceIdentifier id, de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<T>> eventQueue, java.io.InputStream inputStream) throws java.io.IOException
createProducer
in class AbstractServerSocketEventSourceProducer<T extends java.io.Serializable>
java.io.IOException
public java.lang.String toString()
toString
in class java.lang.Object