Repository URL to install this package:
Version:
4.3.1 ▾
|
ó Éec @ sn d d l Z d d l m Z d a i a e j Z d Z d e e d Z e d d d Z d Z d S( iÿÿÿÿN( t serializert __default__c C s t j d d S( Nt dmapi( t oslo_messagingt set_transport_defaults( ( ( s3 /usr/lib/python2.7/dist-packages/dmapi/messaging.pyt setup s c C s | p t } t j | } | s) | r y t j | | } Wn1 t j t j f k rr | sh | rn n d SX| r | t | <q n | S( s$ Initialise the oslo_messaging layer.N( t DEFAULT_URLt TRANSPORTSt getR t get_notification_transportt InvalidTransportURLt DriverLoadFailuret None( t conft urlt optionalt cachet cache_keyt transport( ( s3 /usr/lib/python2.7/dist-packages/dmapi/messaging.pyt get_transport s i c C s+ t j | | | d d d | d | d | S( s9 Return a configured oslo_messaging notification listener.t executort threadingt allow_requeuet batch_sizet batch_timeout( R t get_batch_notification_listener( R t targetst endpointsR R R ( ( s3 /usr/lib/python2.7/dist-packages/dmapi/messaging.pyR % s c C s% t j | d t } | j d | S( s, Return a configured oslo_messaging notifier.R t publisher_id( R t Notifiert _SERIALIZERt prepare( R R t notifier( ( s3 /usr/lib/python2.7/dist-packages/dmapi/messaging.pyt get_notifier/ s ( R R t oslo_serializerR R t JsonPayloadSerializerR R R t Falset TrueR R R! ( ( ( s3 /usr/lib/python2.7/dist-packages/dmapi/messaging.pyt <module> s