Package org.nuxeo.ecm.core.blob.stream

Class BlobDomainEventProducer

java.lang.Object

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

org.nuxeo.ecm.core.blob.stream.BlobDomainEventProducer

public class BlobDomainEventProducer
extends DomainEventProducer

Since:

2023

Field Summary

Fields

Modifier and Type	Field	Description
protected Codec<BlobDomainEvent>	codec
protected static String	CODEC_NAME
protected static String	EMPTY_PNG
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
BlobDomainEventProducer(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(String name, BlobEventContext ctx)
protected boolean	exclude(String event, ManagedBlob blob)
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

EMPTY_PNG

protected static final String EMPTY_PNG

See Also:

Constant Field Values

codec

protected final Codec<BlobDomainEvent> codec

records

protected final List<Record> records

Constructor Detail

BlobDomainEventProducer

public BlobDomainEventProducer(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

exclude

protected boolean exclude(String event,
                          ManagedBlob blob)

buildRecordFromEvent

protected Record buildRecordFromEvent(String name,
                                      BlobEventContext 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