Package org.nuxeo.audit.stream

Class AuditDomainEventProducer

java.lang.Object

org.nuxeo.ecm.core.event.stream.DomainEventProducer

org.nuxeo.audit.stream.AuditDomainEventProducer

public class AuditDomainEventProducer
extends DomainEventProducer

Audit domain event producer.

Since:

11.4

Field Summary

Fields

Modifier and Type	Field	Description
protected final Codec<AuditDomainEvent>	codec
protected static final String	CODEC_NAME
protected static final org.apache.logging.log4j.Logger	log
protected static final com.fasterxml.jackson.databind.ObjectMapper	MAPPER
protected final List<Record>	records
protected static final String	SOURCE_NAME

Fields inherited from class org.nuxeo.ecm.core.event.stream.DomainEventProducer

name, stream

Constructor Summary

Constructors

Constructor	Description
AuditDomainEventProducer(String name, String stream)

Method Summary

Modifier and Type	Method	Description
void	addEvent(Event event)	Receives Nuxeo Core events from the synchronous listener DomainEventProducerListener.
protected Record	buildRecordFromEvent(LogEntry entry)
List<Record>	getDomainEvents()	Produces Domain Event Records from the accumulated Nuxeo Core events.

Methods inherited from class org.nuxeo.ecm.core.event.stream.DomainEventProducer

getName, getStream, maxPerPartition, postCommitHook

Methods inherited from class java.lang.Object

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

Field Details

log

protected static final org.apache.logging.log4j.Logger log

SOURCE_NAME

protected static final String SOURCE_NAME

See Also:

• Constant Field Values

MAPPER

protected static final com.fasterxml.jackson.databind.ObjectMapper MAPPER

CODEC_NAME

protected static final String CODEC_NAME

See Also:

• Constant Field Values

records

protected final List<Record> records

codec

protected final Codec<AuditDomainEvent> codec

Constructor Details

AuditDomainEventProducer

public AuditDomainEventProducer(String name,
 String stream)

Method Details

addEvent

public void addEvent(Event event)

Description copied from class: DomainEventProducer

Receives Nuxeo Core events from the synchronous listener DomainEventProducerListener.

Specified by:

addEvent in class DomainEventProducer

buildRecordFromEvent

protected Record buildRecordFromEvent(LogEntry entry)

getDomainEvents

public List<Record> getDomainEvents()

Description copied from class: DomainEventProducer

Produces Domain Event Records from the accumulated Nuxeo Core events.

Specified by:

getDomainEvents in class DomainEventProducer