com.netflix.astyanax.util
Class BlockingAckingQueue

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

All Implemented Interfaces:

AckingQueue

public class BlockingAckingQueue
extends java.lang.Object
implements AckingQueue

Constructor Summary

BlockingAckingQueue()

Method Summary

void	ackMutation(MutationBatch m) Ack a mutation so that it may be removed from the queue
MutationBatch	getNextMutation(long timeout, java.util.concurrent.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

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockingAckingQueue

public BlockingAckingQueue()

Method Detail

getNextMutation

public MutationBatch getNextMutation(long timeout,
                                     java.util.concurrent.TimeUnit unit)
                              throws java.lang.InterruptedException

Description copied from interface: AckingQueue

Get the next item from the queue

Specified by:

getNextMutation in interface AckingQueue

Returns:

Throws:

java.lang.InterruptedException

pushMutation

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

Description copied from interface: AckingQueue

Insert an item into the queue

Specified by:

pushMutation in interface AckingQueue

Throws:

java.lang.Exception

ackMutation

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

Description copied from interface: AckingQueue

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

Specified by:

ackMutation in interface AckingQueue

Throws:

java.lang.Exception

repushMutation

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

Description copied from interface: AckingQueue

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

Specified by:

repushMutation in interface AckingQueue

Throws:

java.lang.Exception

size

public int size()

Description copied from interface: AckingQueue

Return the number of mutations in the queue

Specified by:

size in interface AckingQueue

Returns: