| Package | Description |
|---|---|
| org.nuxeo.ecm.platform.audit.listener | |
| org.nuxeo.importer.stream.consumer | |
| org.nuxeo.lib.stream.log |
The Log interface with Chronicle and Kafka implementation.
|
| org.nuxeo.lib.stream.log.chronicle | |
| org.nuxeo.lib.stream.log.internals | |
| org.nuxeo.lib.stream.log.kafka | |
| org.nuxeo.lib.stream.pattern.producer.internals | |
| org.nuxeo.runtime.pubsub |
| Modifier and Type | Method and Description |
|---|---|
protected void |
StreamAuditEventListener.writeEntry(LogAppender<Record> appender,
LogEntry entry) |
| Modifier and Type | Field and Description |
|---|---|
protected LogAppender<BlobInfoMessage> |
LogBlobInfoWriter.appender |
| Constructor and Description |
|---|
LogBlobInfoWriter(LogAppender<BlobInfoMessage> blobInfoAppender) |
| Modifier and Type | Method and Description |
|---|---|
default <M extends Externalizable> |
LogManager.getAppender(String name)
Gets an appender for the Log named
name, uses an already defined codec or the legacy encoding to encode
records. |
<M extends Externalizable> |
LogManager.getAppender(String name,
Codec<M> codec)
Gets an appender for the Log named
name, uses codec to encode records. |
| Modifier and Type | Class and Description |
|---|---|
class |
ChronicleLogAppender<M extends Externalizable>
Chronicle Queue implementation of LogAppender.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
CloseableLogAppender<M extends Externalizable> |
| Modifier and Type | Method and Description |
|---|---|
<M extends Externalizable> |
AbstractLogManager.getAppender(String name,
Codec<M> codec) |
| Modifier and Type | Class and Description |
|---|---|
class |
KafkaLogAppender<M extends Externalizable>
Apache Kafka implementation of Log.
|
| Modifier and Type | Field and Description |
|---|---|
protected LogAppender<M> |
ProducerRunner.appender |
| Constructor and Description |
|---|
ProducerRunner(ProducerFactory<M> factory,
LogAppender<M> appender,
int producerId) |
| Modifier and Type | Field and Description |
|---|---|
protected LogAppender<Record> |
StreamPubSubProvider.appender |
Copyright © 2019 Nuxeo. All rights reserved.