public static class SimDistributedQueueFactory.SimDistributedQueue extends Object implements DistributedQueue
Constructor and Description |
---|
SimDistributedQueue(String dir) |
Modifier and Type | Method and Description |
---|---|
Map<String,Object> |
getStats() |
Stats |
getZkStats() |
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) |
byte[] |
poll() |
byte[] |
remove() |
byte[] |
take() |
public SimDistributedQueue(String dir)
public byte[] peek() throws Exception
peek
in interface DistributedQueue
Exception
public byte[] peek(boolean block) throws Exception
peek
in interface DistributedQueue
Exception
public byte[] peek(long wait) throws Exception
peek
in interface DistributedQueue
Exception
public byte[] poll() throws Exception
poll
in interface DistributedQueue
Exception
public byte[] remove() throws Exception
remove
in interface DistributedQueue
Exception
public byte[] take() throws Exception
take
in interface DistributedQueue
Exception
public void offer(byte[] data) throws Exception
offer
in interface DistributedQueue
Exception
public Collection<Pair<String,byte[]>> peekElements(int max, long waitMillis, Predicate<String> acceptFilter) throws Exception
peekElements
in interface DistributedQueue
Exception
public Stats getZkStats()
public Map<String,Object> getStats()
getStats
in interface DistributedQueue
Copyright © 2000-2019 Apache Software Foundation. All Rights Reserved.