Package com.persequor.saga.modules.compliance.services

Class ConditionalCassandraDataCleaner

java.lang.Object

com.persequor.saga.modules.compliance.services.ConditionalCassandraDataCleaner

All Implemented Interfaces:

IConditionalDataCleaner

public class ConditionalCassandraDataCleaner
extends Object
implements IConditionalDataCleaner

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConditionalCassandraDataCleaner.BlockingExecutor	This is based on the implementation from Saga Core

Constructor Summary

Constructors

Constructor	Description
ConditionalCassandraDataCleaner(com.persequor.extension.db.IConnectivityService connectivityService)

Method Summary

Modifier and Type	Method	Description
void	clean(String searchTable, String searchStatement, Consumer<com.persequor.cassandra.ICassandraSettableData<?>> searchConditions, String targetTable, Function<com.persequor.cassandra.Row,Consumer<com.persequor.cassandra.WhereStatementCreator>> rowToDeleteConditions)	Deprecated.
void	cleanRepliesCreatedBefore(ZonedDateTime cutOff)
void	cleanRequestLogsRequestedBefore(ZonedDateTime cutOff)

Methods inherited from class java.lang.Object

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

Constructor Details

ConditionalCassandraDataCleaner

@Inject
public ConditionalCassandraDataCleaner(com.persequor.extension.db.IConnectivityService connectivityService)

Method Details

cleanRequestLogsRequestedBefore

public void cleanRequestLogsRequestedBefore(ZonedDateTime cutOff)

Specified by:

cleanRequestLogsRequestedBefore in interface IConditionalDataCleaner

cleanRepliesCreatedBefore

public void cleanRepliesCreatedBefore(ZonedDateTime cutOff)

Specified by:

cleanRepliesCreatedBefore in interface IConditionalDataCleaner

clean

@Deprecated
public void clean(String searchTable,
 String searchStatement,
 Consumer<com.persequor.cassandra.ICassandraSettableData<?>> searchConditions,
 String targetTable,
 Function<com.persequor.cassandra.Row,Consumer<com.persequor.cassandra.WhereStatementCreator>> rowToDeleteConditions)

Deprecated.

Deprecated, please use the specialized methods (cleanRequestedBefore(ZonedDateTime) and cleanCreatedBefore(ZonedDateTime)) instead