public interface

AckingQueue

com.netflix.astyanax.impl.AckingQueue
Known Indirect Subclasses

Class Overview

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

Summary

Public Methods
abstract void ackMutation(MutationBatch m)
Ack a mutation so that it may be removed from the queue
abstract MutationBatch getNextMutation(long timeout, TimeUnit units)
Get the next item from the queue
abstract void pushMutation(MutationBatch m)
Insert an item into the queue
abstract void repushMutation(MutationBatch m)
Return a mutation that couldn't be retried for it be requeued and retryed later
abstract int size()
Return the number of mutations in the queue

Public Methods

public abstract void ackMutation (MutationBatch m)

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

Throws
Exception

public abstract MutationBatch getNextMutation (long timeout, TimeUnit units)

Get the next item from the queue

Throws
InterruptedException

public abstract void pushMutation (MutationBatch m)

Insert an item into the queue

Throws
Exception

public abstract void repushMutation (MutationBatch m)

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

Throws
Exception

public abstract int size ()

Return the number of mutations in the queue