Package org.nuxeo.audit.listener

Class StreamAuditEventListener

java.lang.Object
org.nuxeo.audit.listener.StreamAuditEventListener
All Implemented Interfaces:
jakarta.transaction.Synchronization, EventListener
public class StreamAuditEventListener extends Object implements EventListener, jakarta.transaction.Synchronization
An events collector that write log entries as json record into a stream.
Since:
9.3

  • Field Details

  • Constructor Details

    • StreamAuditEventListener

      public StreamAuditEventListener()

  • Method Details

    • handleVirtualEvents

      protected boolean handleVirtualEvents()

    • handleEvent

      public void handleEvent(Event event)
      Description copied from interface: EventListener
      Handle the given event. The listener can cancel the event by calling Event.cancel()
      Specified by:
      handleEvent in interface EventListener
      Parameters:
      event - the event

    • extractVirtualEvents

      protected Collection<? extends LogEntry> extractVirtualEvents(Object[] args)

    • beforeCompletion

      public void beforeCompletion()
      Specified by:
      beforeCompletion in interface jakarta.transaction.Synchronization

    • afterCompletion

      public void afterCompletion(int status)
      Specified by:
      afterCompletion in interface jakarta.transaction.Synchronization

    • writeEntries

      protected void writeEntries()

    • getPartitionKey

      protected String getPartitionKey()

    • recordOf

      protected Record recordOf(LogEntry entry)

    • recordOf

      protected Record recordOf(String partitionKey, LogEntry entry)

    • getTimestampForEntry

      protected long getTimestampForEntry(LogEntry entry)

    • asJson

      protected String asJson(LogEntry entry)

    • registerSynchronization

      protected boolean registerSynchronization(jakarta.transaction.Synchronization sync)

    • getStreamManager

      protected StreamManager getStreamManager()