Package com.broadleafcommerce.audit.service

Class AuditIngestionService

java.lang.Object

com.broadleafcommerce.audit.service.AuditIngestionService

All Implemented Interfaces:

org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

public class AuditIngestionService
extends Object
implements org.springframework.context.SmartLifecycle

Responsible for querying the StorageProvider for completed Batch representations and pushing those to the IngestionProcessor for parsing and subsequent persistence in the datastore.

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	started

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
AuditIngestionService(org.springframework.scheduling.TaskScheduler scheduler, AuditIngestionProperties properties, com.broadleafcommerce.common.audit.batch.StorageProvider storageProvider, IngestionProcessor ingestionProcessor)

Method Summary

Modifier and Type	Method	Description
boolean	isAutoStartup()
boolean	isRunning()
boolean	isStarted()
void	process()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.context.SmartLifecycle

getPhase, stop

Field Details

started

protected boolean started

Constructor Details

AuditIngestionService

public AuditIngestionService(org.springframework.scheduling.TaskScheduler scheduler,
 AuditIngestionProperties properties,
 com.broadleafcommerce.common.audit.batch.StorageProvider storageProvider,
 IngestionProcessor ingestionProcessor)

Method Details

isAutoStartup

public boolean isAutoStartup()

Specified by:

isAutoStartup in interface org.springframework.context.SmartLifecycle

start

public void start()

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public void stop()

Specified by:

stop in interface org.springframework.context.Lifecycle

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle

process

public void process()

isStarted

public boolean isStarted()