Package org.nuxeo.ecm.core.event.stream

Class DomainEventProducer

java.lang.Object
org.nuxeo.ecm.core.event.stream.DomainEventProducer
Direct Known Subclasses:
AuditDomainEventProducer, BlobDomainEventProducer, DocumentDomainEventProducer, IndexingDomainEventProducer
public abstract class DomainEventProducer extends Object
Collects Core Events and produces Domain Event Records.
Since:
11.4

  • Field Details

    • name

      protected final String name

    • stream

      protected final String stream

  • Constructor Details

    • DomainEventProducer

      public DomainEventProducer(String name, String stream)

  • Method Details

    • getName

      public String getName()
      The name of the domain event.

    • getStream

      public String getStream()

    • addEvent

      public abstract void addEvent(Event event)
      Receives Nuxeo Core events from the synchronous listener DomainEventProducerListener.

    • getDomainEvents

      public abstract List<Record> getDomainEvents()
      Produces Domain Event Records from the accumulated Nuxeo Core events.

    • postCommitHook

      public void postCommitHook(List<LogOffset> offsets)
      This hook is called once the records have been produced downstream, providing the list of produced record offsets.
      Since:
      2025.0

    • maxPerPartition

      public List<LogOffset> maxPerPartition(List<LogOffset> offsets)
      Helper that returns the higher offsets per partitions.
      Since:
      2025.0