package org.ds;

import org.apache.zookeeper.*;
import org.ds.interfaces.Queue;
import org.ds.utils.DistributedLock;
import org.ds.utils.Helper;

import java.util.List;

public class LockQueue implements Queue {
    private ZooKeeper zk;
    private String queuePath;

    public LockQueue(ZooKeeper zk, String queuePath) throws InterruptedException, KeeperException {
        this.zk = zk;
        this.queuePath = queuePath;
        Helper.createNodeIfDoesNotExists(zk, queuePath);
    }

    public void enqueue(String item) throws Exception {
        // Create an item node under the queue node with the item data

    }

    public String dequeue() throws Exception {
        return "";
    }
}