|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.netflix.astyanax.util.BlockingAckingQueue
public class BlockingAckingQueue
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,
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 |
---|
public BlockingAckingQueue()
Method Detail |
---|
public MutationBatch getNextMutation(long timeout, TimeUnit unit) throws InterruptedException
AckingQueue
getNextMutation
in interface AckingQueue
InterruptedException
public void pushMutation(MutationBatch m) throws Exception
AckingQueue
pushMutation
in interface AckingQueue
Exception
public void ackMutation(MutationBatch m) throws Exception
AckingQueue
ackMutation
in interface AckingQueue
Exception
public void repushMutation(MutationBatch m) throws Exception
AckingQueue
repushMutation
in interface AckingQueue
Exception
public int size()
AckingQueue
size
in interface AckingQueue
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |