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 ofAuditEvent
instances to process- Returns:
- A future callback for async completion handling
-