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

    Modifier and Type
    Method
    Description
    org.springframework.util.concurrent.ListenableFuture<String>
    process(com.broadleafcommerce.common.audit.batch.Batch ingest)
    Parse and process Batch
  • Method Details

    • process

      org.springframework.util.concurrent.ListenableFuture<String> process(com.broadleafcommerce.common.audit.batch.Batch ingest)
      Parse and process Batch
      Parameters:
      ingest - The batch of AuditEvent instances to process
      Returns:
      A future callback for async completion handling