public class AccessEventProtobufMessageBasedEventProducer extends MessageBasedEventProducer<AccessEvent>
Constructor and Description |
---|
AccessEventProtobufMessageBasedEventProducer(SourceIdentifier sourceIdentifier,
de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<AccessEvent>> eventQueue,
java.io.InputStream inputStream,
boolean compressing) |
close, start
addEvent, getEventQueue, getSourceIdentifier
public AccessEventProtobufMessageBasedEventProducer(SourceIdentifier sourceIdentifier, de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<AccessEvent>> eventQueue, java.io.InputStream inputStream, boolean compressing)