@@ -35,7 +35,7 @@ class ZooKeeperQueue(object): def dequeue(self): while True: children = sorted(zookeeper.get_children(self.handle, self.queuename,None)) - if len(child) == 0: + if len(children) == 0: return None for child in children: data = self.get_and_delete(self.queuename + "/" + children[0]) @@ -77,9 +77,9 @@ if __name__ == '__main__': print "Done" print "Consuming all items in queue" - v = zk.block_dequeue() + v = zk.dequeue() while v != None: print v - v = zk.block_dequeue() + v = zk.dequeue() print "Done" queue.py 324cd725c59bb3a7c87233e8e743df4eb2313283 Henry Robinson henry@lamport.local http://github.com/henryr/pyzk-recipes/commit/db8a3bf89648d8c1740351c1d43cdf1efb7e2a4c db8a3bf89648d8c1740351c1d43cdf1efb7e2a4c 2009-05-27T16:56:01-07:00 2009-05-27T16:56:01-07:00 Tiny fix - example shouldn't hang for ever after last item 8984277ee623b2d079c8bd0cde4e32722d67c503 Henry Robinson henry@lamport.local