org.apache.accumulo.fate.zookeeper
Class ZooQueueLock
java.lang.Object
org.apache.accumulo.fate.zookeeper.ZooQueueLock
- All Implemented Interfaces:
- DistributedReadWriteLock.QueueLock
- Direct Known Subclasses:
- ZooQueueLock
public class ZooQueueLock
- extends Object
- implements DistributedReadWriteLock.QueueLock
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ZooQueueLock
public ZooQueueLock(String zookeepers,
int timeInMillis,
String scheme,
byte[] auth,
String path,
boolean ephemeral)
throws org.apache.zookeeper.KeeperException,
InterruptedException
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
ZooQueueLock
protected ZooQueueLock(IZooReaderWriter zrw,
String path,
boolean ephemeral)
addEntry
public long addEntry(byte[] data)
- Specified by:
addEntry
in interface DistributedReadWriteLock.QueueLock
getEarlierEntries
public SortedMap<Long,byte[]> getEarlierEntries(long entry)
- Specified by:
getEarlierEntries
in interface DistributedReadWriteLock.QueueLock
removeEntry
public void removeEntry(long entry)
- Specified by:
removeEntry
in interface DistributedReadWriteLock.QueueLock
Copyright © 2013 Apache Accumulo Project. All Rights Reserved.