
O'^c           @@  s\   d  d l  m Z d  d l m Z d  d l m Z m Z m Z m Z d e f d     YZ	 d S(   i    (   t   absolute_import(   t
   Connection(   t   Caset   mask_modulest   module_existst   patcht   test_get_managerc           B@  sG   e  Z e d   d    Z e d   d    Z e d   d    Z RS(   t   pyrabbitc         C@  s*   |  j  t   t d  j   Wd  QXd  S(   Ns   amqp://(   t   assertRaisest   ImportErrorR   t   get_manager(   t   self(    (    sD   /tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_amq_manager.pyt   test_without_pyrabbit
   s    c         C@  sQ   t  d d t 9 } t d  j   } |  j |  | j d d d  Wd  QXd  S(   Ns   pyrabbit.Clientt   creates   amqp://s   localhost:15672t   guest(   R   t   TrueR   R
   t   assertIsNotNonet   assert_called_with(   R   t   Clientt   manager(    (    sD   /tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_amq_manager.pyt   test_with_pyrabbit   s
    c      
   C@  ss   t  d d t [ } t d d i d d 6d d 6d	 d
 6d d 6j   } |  j |  | j d d	 d  Wd  QXd  S(   Ns   pyrabbit.ClientR   s   amqp://t   transport_optionss   admin.mq.vandelay.comt   manager_hostnamei(  t   manager_portt   georget   manager_useridt   boscot   manager_passwords   admin.mq.vandelay.com:808(   R   R   R   R
   R   R   (   R   R   R   (    (    sD   /tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_amq_manager.pyt   test_transport_options   s    (   t   __name__t
   __module__R   R   R   R   R   (    (    (    sD   /tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_amq_manager.pyR      s   	N(
   t
   __future__R    t   kombuR   t   kombu.tests.caseR   R   R   R   R   (    (    (    sD   /tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_amq_manager.pyt   <module>   s   "