??????????????
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 173
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 174
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 175
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 176
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 177
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 178
ó
ßUdac @` sè d d l m Z m Z m Z e Z d d l m Z d d l m Z d d l
m Z d d l Z d d l
Z
d Z y2 d d l Z d d l Z d d l m Z e Z Wn# e k
rÇ e
j ƒ Z e Z n Xd „ Z d d
d „ ƒ YZ d S( i ( t absolute_importt divisiont print_function( t to_native( t missing_required_lib( t MimeTypesN( t specc C` sß t d t d d d d ƒ d t d d d d d t ƒ d t d d d d ƒ d
t d d d d ƒ d t d d d d
d d
d g ƒ d t d d d d g ƒ d t d d d d g ƒ d t d d d d g ƒ d t d d d d ƒ ƒ S( Nt
login_usert typet strt defaultt guestt login_passwordt no_logt
login_hostt localhostt
login_portt 15672t login_protocolt httpt choicest httpst ca_certt patht aliasest cacertt client_certt certt
client_keyt keyt vhostt /( t dictt True( ( ( sA /usr/lib/python2.7/site-packages/ansible/module_utils/rabbitmq.pyt rabbitmq_argument_spec s !t RabbitClientc B` sn e Z d „ Z d „ Z d „ Z e d „ ƒ Z d „ Z e d „ ƒ Z d „ Z d „ Z
d „ Z d „ Z RS(
c C` sã | | _ | j | _ | j ƒ | j ƒ | j d | _ | j d | _ | j d | _ | j d | _ | j d | _ | j d | _ | j d | _
| j d | _ | j d | _ | j d k rÕ | j ƒ n | j ƒ d S(
Nt urlt protot usernamet passwordt hostt portR t queuet headers( t modulet paramst check_required_libraryt check_host_paramsR$ R% R& R' R( R) R R* R+ t Nonet build_urlt connect_to_rabbitmq( t selfR, ( ( sA /usr/lib/python2.7/site-packages/ansible/module_utils/rabbitmq.pyt __init__- s
c C` s, t s( | j j d t d ƒ d t ƒ n d S( Nt msgt pikat exception( t HAS_PIKAR, t fail_jsonR t PIKA_IMP_ERR( R3 ( ( sA /usr/lib/python2.7/site-packages/ansible/module_utils/rabbitmq.pyR. A s c
` s² ˆ j d d k rW t ‡ f d † d d d d d d g Dƒ ƒ rW ˆ j j d d
ƒ n ˆ j d d k r® t ‡ f d † d d d d d d g Dƒ ƒ r® ˆ j j d d ƒ n d S(
NR$ c 3` s" | ] } ˆ j | d k Vq d S( N( R- R0 ( t .0t k( R3 ( sA /usr/lib/python2.7/site-packages/ansible/module_utils/rabbitmq.pys G s R% R( R) R' R& R R5 s\ url and proto, host, port, vhost, username or password cannot be specified at the same time.c 3` s" | ] } ˆ j | d k Vq d S( N( R- R0 ( R; R< ( R3 ( sA /usr/lib/python2.7/site-packages/ansible/module_utils/rabbitmq.pys K s sb Connection parameters must be passed via url, or, proto, host, port, vhost, username or password.( R- R0 t anyR, R9 ( R3 ( ( R3 sA /usr/lib/python2.7/site-packages/ansible/module_utils/rabbitmq.pyR/ E s AAc C` s‘ t d t d d ƒ d t d d d d d g ƒ d t d d ƒ d t d d
ƒ d t d d ƒ d t d d d
t ƒ d t d d ƒ d t d d ƒ ƒ S( NR$ R R R% R t amqpt amqpsR( R) t intR& R' R
R R* ( R R! ( ( ( sA /usr/lib/python2.7/site-packages/ansible/module_utils/rabbitmq.pyR" N s c C` sc y& t | d ƒ } | j ƒ SWd QXWn6 t k
r^ } | j j d d | t | ƒ f ƒ n Xd S( Nt rbR5 s Unable to open file %s: %s( t opent readt IOErrorR, R9 R ( R3 R t file_handlet e( ( sA /usr/lib/python2.7/site-packages/ansible/module_utils/rabbitmq.pyt
_read_file\ s
c C` s t ƒ } | j | ƒ S( N( R t
guess_type( R t mime( ( sA /usr/lib/python2.7/site-packages/ansible/module_utils/rabbitmq.pyt _check_file_mime_typec s c C` s7 d j | j | j | j | j | j | j ƒ | _ d S( Ns {0}://{1}:{2}@{3}:{4}/{5}( t formatR% R& R' R( R) R R$ ( R3 ( ( sA /usr/lib/python2.7/site-packages/ansible/module_utils/rabbitmq.pyR1 h s c C` sï y t j | j ƒ } Wn0 t k
rH } | j j d d t | ƒ ƒ n Xy t j | ƒ | _ Wn0 t k
r‘ } | j j d d t | ƒ ƒ n Xy | j j ƒ | _
Wn@ t j j k
rê } | j
ƒ | j j d d t | ƒ ƒ n Xd S( sM
Function to connect to rabbitmq using username and password
R5 s URL malformed: %ss Connection issue: %ss Channel issue: %sN( R6 t
URLParametersR$ t ExceptionR, R9 R t BlockingConnectiont
connectiont channelt conn_channelt
exceptionst AMQPChannelErrort close_connection( R3 t
parametersRF ( ( sA /usr/lib/python2.7/site-packages/ansible/module_utils/rabbitmq.pyR2 p s !!
c C` s/ y | j j ƒ Wn t j j k
r* n Xd S( N( RO t closeR6 RR t AMQPConnectionError( R3 ( ( sA /usr/lib/python2.7/site-packages/ansible/module_utils/rabbitmq.pyRT „ s c C` st | j j d ƒ | _ | j j d ƒ d k r“ t d | j j d ƒ d | j j d ƒ d | j j d ƒ d t j d | j d d d | j ƒ ƒ } n | j j d ƒ d k rv| j d
k rvt j | j j d ƒ ƒ d | _ | j j
d t j j
| j j d ƒ ƒ ƒ t d | j | j j d ƒ ƒ d | j j d ƒ d | j j d ƒ d t j d | j d d d | j ƒ ƒ } n‡ | j j d ƒ d k rýt d | j | j j d ƒ ƒ d | j j d ƒ d | j j d ƒ d t j d | j d d d | j ƒ ƒ } n yÐ | j d k rs| j j d
| j j d
ƒ d | j j d ƒ d | j j d ƒ ƒ } | j j ƒ | j j | _ nY | j j d | j d
| j j d
ƒ d | j j d ƒ d | j j d ƒ ƒ | j j ƒ Wn0 t k
rÿ} | j j d d t | ƒ ƒ n X| d d k r | j | d s"