/usr/lib/python2.6/site-packages/openstack/message/v1
Edit: /usr/lib/python2.6/site-packages/openstack/message/v1/message.pyc (3172B)
Ñò
5
Wc @ sr d d k Z d d k l Z d d k l Z d d k l Z d e i f d „ ƒ YZ d e i f d „ ƒ YZ
d S( iÿÿÿÿN( t parse( t message_service( t resourcet Messagec B s° e Z d Z d Z e i ƒ Z e Z e Z
e Z e Z d Z d Z e i d ƒ Z e i d ƒ Z e i d ƒ Z e i d ƒ Z e d „ ƒ Z e d „ ƒ Z e d d „ ƒ Z RS(
t messagess /queues/%(queue_name)s/messagest hreft bodyt ttlt agec
C s[ t | ƒ d j o t d ƒ ‚ n xk t | d ƒ D]Z \ } } | i | | i j o t d ƒ ‚ n | i | | i j o t d ƒ ‚ q3 q3 W| i h | d i d 6ƒ } h | d i d 6} | i | d | i d | d
t i | d t
ƒƒ} | i ƒ } g } | d } xC t | ƒ D]5 \ } }
t i | | } |
| _
| i | ƒ q W| S(
Ni s messages cannot be emptyiÿÿÿÿs$ All queues in messages must be equals% All clients in messages must be equalt
queue_names Client-IDt endpoint_filtert headerst datat clst resources( t lent
ValueErrort enumerateR t client_idt _get_urlt postt servicet jsont dumpst MessageEncoderR t existingR t append( R
t sessionR t it messaget urlR t respt messages_createdt hrefsR ( ( sB /tmp/pip-build-wCUybK/openstacksdk/openstack/message/v1/message.pyt create_messages: s*
c C s? t i | ƒ i } | i d ƒ o | | i d d ƒ S| Sd S( Ns /vt /i ( R t urlparset patht
startswitht find( R
R R% ( ( sB /tmp/pip-build-wCUybK/openstacksdk/openstack/message/v1/message.pyt _strip_versionV s c C sI | i | i ƒ } h | i d 6d d 6} | i | d | i d | ƒd S( Ns Client-IDt t AcceptR
R ( R( R R t deleteR ( R
R R t path_argsR R ( ( sB /tmp/pip-build-wCUybK/openstacksdk/openstack/message/v1/message.pyt delete_by_id_ s
N( t __name__t
__module__t
resources_keyt base_pathR t MessageServiceR t Truet allow_createt Falset
allow_listt allow_retrievet allow_deletet NoneR R R t propR R R R t classmethodR" R( R- ( ( ( sB /tmp/pip-build-wCUybK/openstacksdk/openstack/message/v1/message.pyR s" R c B s e Z d „ Z RS( c C s h | i d 6| i d 6S( NR R ( R R ( t selfR ( ( sB /tmp/pip-build-wCUybK/openstacksdk/openstack/message/v1/message.pyt defaultj s ( R. R/ R= ( ( ( sB /tmp/pip-build-wCUybK/openstacksdk/openstack/message/v1/message.pyR i s ( R t six.moves.urllibR t openstack.messageR t openstackR t ResourceR t JSONEncoderR ( ( ( sB /tmp/pip-build-wCUybK/openstacksdk/openstack/message/v1/message.pyt
s
T