java.lang.Object | |
↳ | com.netflix.astyanax.util.BlockingAckingQueue |
Public Constructors | |||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|
Public Methods | |||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|
Ack a mutation so that it may be removed from the queue
| |||||||||||
Get the next item from the queue
| |||||||||||
Insert an item into the queue
| |||||||||||
Return a mutation that couldn't be retried for it be requeued and retryed
later
| |||||||||||
Return the number of mutations in the queue
|
[Expand]
Inherited Methods | |||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|
From class
java.lang.Object
| |||||||||||
From interface
com.netflix.astyanax.impl.AckingQueue
|
Ack a mutation so that it may be removed from the queue
Exception |
---|
Get the next item from the queue
InterruptedException |
---|
Return a mutation that couldn't be retried for it be requeued and retryed later
Exception |
---|
Return the number of mutations in the queue