Interface IngestionProcessor
- All Known Implementing Classes:
FileSystemIngestionProcessor
public interface IngestionProcessor
Asynchronously parses
Batch representations into AuditEvent instances. Then,
batches those instances according to AuditIngestionProperties.getAuditRecordBatchSize()
and passes to CustomizedAuditHeaderRepository.flushBatch(List) for persistence.-
Method Summary
-
Method Details
-
process
org.springframework.util.concurrent.ListenableFuture<String> process(com.broadleafcommerce.common.audit.batch.Batch ingest) Parse and processBatch- Parameters:
ingest- The batch ofAuditEventinstances to process- Returns:
- A future callback for async completion handling
-