Package org.nuxeo.ecm.core.search.index

Class IndexingDomainEventProducer

java.lang.Object

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

org.nuxeo.ecm.core.search.index.IndexingDomainEventProducer

public class IndexingDomainEventProducer
extends DomainEventProducer

Since:

2025.0

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	anySyncCommand
protected final Codec<IndexingDomainEvent>	codec
static final String	CODEC_NAME
static final String	DISABLE_AUTO_INDEXING
protected final io.dropwizard.metrics5.MetricRegistry	registry
protected static final String	SOURCE_NAME
protected final ThreadLocalIndexingCommandsStacker	stacker
protected final StreamManager	streamManager
static final String	SYNC_INDEXING_FLAG
protected final io.dropwizard.metrics5.Timer	syncWaitTimer

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

name, stream

Constructor Summary

Constructors

Constructor	Description
IndexingDomainEventProducer(String name, String stream)

Method Summary

Modifier and Type	Method	Description
void	addEvent(Event event)	Receives Nuxeo Core events from the synchronous listener DomainEventProducerListener.
List<Record>	getDomainEvents()	Produces Domain Event Records from the accumulated Nuxeo Core events.
protected void	markLastRecordAsEndOfBatch(List<Record> ret)
void	postCommitHook(List<LogOffset> offsets)	This hook is called once the records have been produced downstream, providing the list of produced record offsets.

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

getName, getStream, maxPerPartition

Methods inherited from class java.lang.Object

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

Field Details

DISABLE_AUTO_INDEXING

public static final String DISABLE_AUTO_INDEXING

See Also:

• Constant Field Values

SYNC_INDEXING_FLAG

public static final String SYNC_INDEXING_FLAG

See Also:

• Constant Field Values

CODEC_NAME

public static final String CODEC_NAME

See Also:

• Constant Field Values

SOURCE_NAME

protected static final String SOURCE_NAME

See Also:

• Constant Field Values

registry

protected final io.dropwizard.metrics5.MetricRegistry registry

stacker

protected final ThreadLocalIndexingCommandsStacker stacker

codec

protected final Codec<IndexingDomainEvent> codec

streamManager

protected final StreamManager streamManager

syncWaitTimer

protected final io.dropwizard.metrics5.Timer syncWaitTimer

anySyncCommand

protected boolean anySyncCommand

Constructor Details

IndexingDomainEventProducer

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

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

markLastRecordAsEndOfBatch

protected void markLastRecordAsEndOfBatch(List<Record> ret)

postCommitHook

public void postCommitHook(List<LogOffset> offsets)

Description copied from class: DomainEventProducer

This hook is called once the records have been produced downstream, providing the list of produced record offsets.

Overrides:

postCommitHook in class DomainEventProducer