com.netflix.astyanax.util
Class MutationBatchExecutorWithQueue

java.lang.Object
  com.netflix.astyanax.util.MutationBatchExecutorWithQueue

public class MutationBatchExecutorWithQueue
extends java.lang.Object

Constructor Summary

MutationBatchExecutorWithQueue(AckingQueue queue, int nThreads)

Method Summary

void	execute(MutationBatch m)
long	getFailureCount()
long	getSuccessCount()
void	shutdown()
MutationBatchExecutorWithQueue	startConsumers()
MutationBatchExecutorWithQueue	usingRetryablePredicate(com.google.common.base.Predicate<java.lang.Exception> predicate)

Methods inherited from class java.lang.Object

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

Constructor Detail

MutationBatchExecutorWithQueue

public MutationBatchExecutorWithQueue(AckingQueue queue,
                                      int nThreads)

Method Detail

usingRetryablePredicate

public MutationBatchExecutorWithQueue usingRetryablePredicate(com.google.common.base.Predicate<java.lang.Exception> predicate)

startConsumers

public MutationBatchExecutorWithQueue startConsumers()

execute

public void execute(MutationBatch m)
             throws java.lang.Exception

Throws:

java.lang.Exception

shutdown

public void shutdown()

getFailureCount

public long getFailureCount()

getSuccessCount

public long getSuccessCount()