@retry_on_loss
  def enqueue(self,val):
    zookeeper.create(self.handle, self.queuename+"/item", val, [ZOO_OPEN_ACL_UNSAFE],zookeeper.SEQUENCE)
Adds a new znode whose contents are val to the queue
dataset/ETHPy150Open andreisavu/zookeeper-mq/experiments/queue.py/ZooKeeperQueue.enqueue