Package com.axelor.db.audit

Class AuditProcessor

java.lang.Object

com.axelor.db.audit.AuditProcessor

public class AuditProcessor
extends Object

Service responsible for processing AuditLog.

This processor runs asynchronously (triggered by AsyncAuditQueue) and processes logs in small batches. It employs a "Back-Pressure" mechanism to ensure it does not compete with active user transactions for database resources.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static final record	AuditProcessor.BatchResult

Constructor Summary

Constructors

Constructor	Description
AuditProcessor()
AuditProcessor(BooleanSupplier keepRunningSupplier)

Method Summary

Modifier and Type	Method	Description
void	process()	Process all pending audit logs.
void	process(String txId)	Process audit logs for a specific transaction ID.
protected AuditProcessor.BatchResult	processBatch(String txId, int offset)
static void	signalActivity(Object value)	Signal that entity tracking is happening (called from AuditTracker).

Methods inherited from class java.lang.Object

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

Constructor Details

AuditProcessor

public AuditProcessor()

AuditProcessor

public AuditProcessor(BooleanSupplier keepRunningSupplier)

Method Details

signalActivity

public static void signalActivity(Object value)

Signal that entity tracking is happening (called from AuditTracker). This tells the processor to back off as real work is in progress.

process

public void process()

Process all pending audit logs.

process

public void process(String txId)

Process audit logs for a specific transaction ID.

processBatch

protected AuditProcessor.BatchResult processBatch(String txId,
 int offset)