public class

BlockingAckingQueue

extends Object
implements AckingQueue
java.lang.Object
   ↳ com.netflix.astyanax.util.BlockingAckingQueue

Summary

Public Constructors
BlockingAckingQueue()
Public Methods
void ackMutation(MutationBatch m)
Ack a mutation so that it may be removed from the queue
MutationBatch getNextMutation(long timeout, TimeUnit unit)
Get the next item from the queue
void pushMutation(MutationBatch m)
Insert an item into the queue
void repushMutation(MutationBatch m)
Return a mutation that couldn't be retried for it be requeued and retryed later
int size()
Return the number of mutations in the queue
[Expand]
Inherited Methods
From class java.lang.Object
From interface com.netflix.astyanax.impl.AckingQueue

Public Constructors

public BlockingAckingQueue ()

Public Methods

public void ackMutation (MutationBatch m)

Ack a mutation so that it may be removed from the queue

Throws
Exception

public MutationBatch getNextMutation (long timeout, TimeUnit unit)

Get the next item from the queue

Throws
InterruptedException

public void pushMutation (MutationBatch m)

Insert an item into the queue

Throws
Exception

public void repushMutation (MutationBatch m)

Return a mutation that couldn't be retried for it be requeued and retryed later

Throws
Exception

public int size ()

Return the number of mutations in the queue