public interface DistributedQueue
Queue
.Modifier and Type | Method and Description |
---|---|
Map<String,Object> |
getStats()
Retrieve statistics about the queue size, operations and their timings.
|
void |
offer(byte[] data) |
byte[] |
peek() |
byte[] |
peek(boolean block) |
byte[] |
peek(long wait) |
Collection<Pair<String,byte[]>> |
peekElements(int max,
long waitMillis,
Predicate<String> acceptFilter)
Peek multiple elements from the queue in a single call.
|
byte[] |
poll() |
byte[] |
remove() |
byte[] |
take() |
Map<String,Object> getStats()
Collection<Pair<String,byte[]>> peekElements(int max, long waitMillis, Predicate<String> acceptFilter) throws Exception
max
- maximum elements to retrievewaitMillis
- if less than maximum element is in the queue then wait at most this time for at least one new element.acceptFilter
- peek only elements that pass this filterException
- on errorsCopyright © 2000-2017 Apache Software Foundation. All Rights Reserved.