com.netflix.astyanax.impl
Interface AckingQueue

All Known Implementing Classes:

BlockingAckingQueue

public interface AckingQueue

Abstraction for a durable queue requiring an ack to do the final remove

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 units) 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

Method Detail

getNextMutation

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

Get the next item from the queue

Parameters:

timeout -

units -

Returns:

Throws:

java.lang.InterruptedException

pushMutation

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

Insert an item into the queue

Parameters:

m -

Throws:

java.lang.Exception

ackMutation

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

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

Parameters:

m -

Throws:

java.lang.Exception

repushMutation

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

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

Parameters:

m -

Throws:

java.lang.Exception

size

int size()

Return the number of mutations in the queue

Returns: