|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
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,
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 |
---|
MutationBatch getNextMutation(long timeout, TimeUnit units) throws InterruptedException
timeout
- units
-
InterruptedException
void pushMutation(MutationBatch m) throws Exception
m
-
Exception
void ackMutation(MutationBatch m) throws Exception
m
-
Exception
void repushMutation(MutationBatch m) throws Exception
m
-
Exception
int size()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |