ó
O'—^c           @@  s)   d  d l  m Z d d d d d „ Z d S(   i    (   t   absolute_importc         @  sž   d d  l  } ˆ  j j ‰ ‡  ‡ f d †  } | d | d ƒ } | d  k	 rN | n ˆ d d ƒ } | d | d ƒ } | d	 | d ƒ } | j d
 | | f | | ƒ S(   Ni    c         @  s6   | d  k	 r | Sˆ d |  ƒ p5 t ˆ  |  d  ƒ p5 | S(   Ns
   manager_%s(   t   Nonet   getattr(   t   namet   valt   default(   t   clientt   opt(    s9   /tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/amq_manager.pyt   get	   s    t   hostnamet	   localhostt   manager_porti8=  t   useridt   guestt   passwords   %s:%s(   t   pyrabbitt   transport_optionsR   R   t   Client(   R   R	   t   portR   R   R   R   t   host(    (   R   R   s9   /tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/amq_manager.pyt   get_manager   s    !N(   t
   __future__R    R   R   (    (    (    s9   /tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/amq_manager.pyt   <module>   s   	