Package com.persequor.saga.modules.compliance.model

Class CassandraRetryWrapper

java.lang.Object

com.persequor.saga.modules.compliance.model.CassandraRetryWrapper

public class CassandraRetryWrapper
extends Object

Constructor Summary

Constructors

Constructor	Description
CassandraRetryWrapper(ComplianceModuleProperties complianceModuleProperties, com.persequor.extension.db.IConnectivityService connectivityService)

Method Summary

Modifier and Type	Method	Description
com.persequor.cassandra.CassandraBatch	createBatch()
com.persequor.cassandra.CassandraResultSet	execute(String table, Consumer<com.persequor.cassandra.ICassandraSettableData<?>> mapper)
protected com.persequor.cassandra.CassandraResultSet	handleWithRetries(Supplier<com.persequor.cassandra.CassandraResultSet> supplier)
com.persequor.cassandra.CassandraResultSet	insert(String table, Consumer<com.persequor.cassandra.ICassandraSettableData<?>> mapper)
com.persequor.cassandra.CassandraResultSet	select(String table, Consumer<com.persequor.cassandra.WhereStatementCreator> whereStatementCreatorConsumer)

Methods inherited from class java.lang.Object

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

Constructor Details

CassandraRetryWrapper

@Inject
public CassandraRetryWrapper(ComplianceModuleProperties complianceModuleProperties,
 com.persequor.extension.db.IConnectivityService connectivityService)

Method Details

select

public com.persequor.cassandra.CassandraResultSet select(String table,
 Consumer<com.persequor.cassandra.WhereStatementCreator> whereStatementCreatorConsumer)

insert

public com.persequor.cassandra.CassandraResultSet insert(String table,
 Consumer<com.persequor.cassandra.ICassandraSettableData<?>> mapper)

execute

public com.persequor.cassandra.CassandraResultSet execute(String table,
 Consumer<com.persequor.cassandra.ICassandraSettableData<?>> mapper)

createBatch

public com.persequor.cassandra.CassandraBatch createBatch()

handleWithRetries

protected com.persequor.cassandra.CassandraResultSet handleWithRetries(Supplier<com.persequor.cassandra.CassandraResultSet> supplier)