ó O'—^c@@sñdZddlmZddlZddlZddlmZmZddlm Z ddl m Z ddl m Z d ZyddlZdd lmZdd lmZejjejjejjejjejjejjejjejjejjf Zejjejj ejj!ejjejjejjejj"ejj#ejjejj$ejj%ejj&ejjejj'ej(fZ)Wn!e*k r®dZdZZ)nXd Z,d Z-de j.fd„ƒYZ.de j/fd„ƒYZ/dS(sØ kombu.transport.zookeeper ========================= Zookeeper transport. :copyright: (c) 2010 - 2013 by Mahendra M. :license: BSD, see LICENSE for more details. **Synopsis** Connects to a zookeeper node as :/ The becomes the base for all the other znodes. So we can use it like a vhost. This uses the built-in kazoo recipe for queues **References** - https://zookeeper.apache.org/doc/trunk/recipes.html#sc_recipes_Queues - https://kazoo.readthedocs.io/en/latest/api/recipe/queue.html **Limitations** This queue does not offer reliable consumption. An entry is removed from the queue prior to being processed. So if an error occurs, the consumer has to re-queue the item or it will be lost. i(tabsolute_importN(tloadstdumps(tEmpty(t bytes_to_stri(tvirtuali (t KazooClient(tQueuei…s!Mahendra M tChannelcB@s}eZd ZiZd„Zd„Zd„Zd„Zd„Z d„Z d„Z d„Z d„Z d „Zed „ƒZRS( cC@stjj|j|ƒS(N(tostpathtjointvhost(tselft queue_name((s;/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zookeeper.pyt _get_pathZscC@sZ|jj|dƒ}|dkrVt|j|j|ƒƒ}||j|RR/t __author__RR;(((s;/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zookeeper.pytsV                          S