Package org.nuxeo.ecm.core.model.stream

Class DocumentDomainEventProducer

java.lang.Object

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

org.nuxeo.ecm.core.model.stream.DocumentDomainEventProducer

public class DocumentDomainEventProducer
extends DomainEventProducer

Propagate internal document events to a document DomainEvent stream.

Since:

2021.44

Field Summary

Fields

Modifier and Type	Field	Description
protected Codec<DocumentDomainEvent>	codec
protected static String	CODEC_NAME
protected static Logger	log
protected List<Record>	records
protected static String	SOURCE_NAME

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

name, stream

Constructor Summary

Constructors

Constructor	Description
DocumentDomainEventProducer(String name, String stream)

Method Summary

Modifier and Type	Method	Description
void	addEvent(Event event)	Receives Nuxeo Core events from the synchronous listener DomainEventProducerListener.
void	addEvent(DocumentDomainEvent event)
protected Record	buildRecordFromEvent(String eventName, DocumentDomainEventContext ctx)
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

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final Logger log

CODEC_NAME

protected static final String CODEC_NAME

See Also:

Constant Field Values

SOURCE_NAME

protected static final String SOURCE_NAME

See Also:

Constant Field Values

codec

protected final Codec<DocumentDomainEvent> codec

records

protected final List<Record> records

Constructor Detail

DocumentDomainEventProducer

public DocumentDomainEventProducer(String name,
                                   String stream)

Method Detail

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

addEvent

public void addEvent(DocumentDomainEvent event)

buildRecordFromEvent

protected Record buildRecordFromEvent(String eventName,
                                      DocumentDomainEventContext ctx)

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