Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
Repository URL to install this package:
|
Version:
5.2.8-5.2 ▾
|
python3-dmapi
/
usr
/
lib
/
python3.6
/
site-packages
/
dmapi
/
__pycache__
/
messaging.cpython-36.opt-1.pyc
|
|---|
3 r`eì ã @ sL d dl Z d dl mZ dai aej Zdd Zddd Zdd d Z d d Z dS )é N)Ú serializerZ __default__c C s t jd d S )NZdmapi)Úoslo_messagingZset_transport_defaults© r r ú /usr/lib/python3.6/messaging.pyÚsetup s r FTc C sh |pt }tj|}| s | rdytj| |}W n( tjtjfk rV | sP|rR dS X |rd|t|< |S )z$Initialise the oslo_messaging layer.N)Ú DEFAULT_URLÚ TRANSPORTSÚgetr Zget_notification_transportZInvalidTransportURLZDriverLoadFailure)ZconfZurlZoptionalÚcacheZ cache_keyÚ transportr r r Ú get_transport s r é c C s t j| ||d|||dS )z9Return a configured oslo_messaging notification listener.Z threading)ÚexecutorÚ allow_requeueÚ batch_sizeÚ batch_timeout)r Ú get_batch_notification_listener)r ZtargetsZ endpointsr r r r r r r % s r c C s t j| td}|j|dS )z,Return a configured oslo_messaging notifier.)r )Ú publisher_id)r ZNotifierÚ _SERIALIZERZprepare)r r Znotifierr r r Ú get_notifier/ s r )NFT)Fr N) r r Zoslo_serializerr r ZJsonPayloadSerializerr r r r r r r r r Ú<module> s