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:
6.0.24-6.0 ▾
|
python3-dmapi
/
usr
/
lib
/
python3.9
/
site-packages
/
dmapi
/
__pycache__
/
messaging.cpython-39.pyc
|
|---|
a
˅rgì ã @ sL d dl Z d dl mZ dai ae ¡ Zdd Zddd Zdd d Z d
d Z
dS )é N©Ú
serializerZ __default__c C s t d¡ d S )NZdmapi)Úoslo_messagingZset_transport_defaults© r r ú3/usr/lib/python3.9/site-packages/dmapi/messaging.pyÚsetup s r FTc C sb |pt }t |¡}|r|s^zt | |¡}W n& tjtjfyP |rH|rJ Y dS 0 |r^|t|< |S )z$Initialise the oslo_messaging layer.N)Ú DEFAULT_URLÚ
TRANSPORTSÚgetr Zget_notification_transportZInvalidTransportURLZDriverLoadFailure)ZconfÚurlZoptionalÚcacheZ cache_keyÚ transportr r r Ú
get_transport s
ÿ
r é c C s t j| ||d|||dS )z9Return a configured oslo_messaging notification listener.Ú threading)ÚexecutorÚ
allow_requeueÚ
batch_sizeÚ
batch_timeout)r Ú get_batch_notification_listener)r
ÚtargetsZ 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
þ