Why Gemfury? Push, build, and install  RubyGems npm packages Python packages Maven artifacts PHP packages Go Modules Debian packages RPM packages NuGet packages

triliodata-3-4 / contego deb

Repository URL to install this package:

Version: 
3.4.37  ▾
Details    
contego / home / tvault / .virtenv / lib / python2.7 / site-packages / oslo_messaging / notify / dispatcher.pyc
Size: Mime: 
ó
čEYc@sÇddlZddlZddlZddlmZddlmZddlmZej	e
ƒZddddd	d
dgZde
fd
„ƒYZdejfd„ƒYZdefd„ƒYZdS(iÿÿÿÿN(t_LW(t
dispatcher(t
serializertaudittdebugtinfotwarnterrortcriticaltsampletNotificationResultcBseZdZdZRS(thandledtrequeue(t__name__t
__module__tHANDLEDtREQUEUE(((sU/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/dispatcher.pyR
 stNotificationDispatchercBs;eZd„Zed„ƒZd„Zd„Zd„ZRS(cCs£||_|ptjƒ|_i|_xutj|tƒD]a\}}t||ƒr:t	||ƒ}t	|ddƒ}|jj|gƒj||fƒq:q:WdS(Ntfilter_rule(
t	endpointstmsg_serializertNoOpSerializerRt_callbacks_by_priorityt	itertoolstproductt
PRIORITIESthasattrtgetattrtNonet
setdefaulttappend(tselfRRtendpointtpriotmethodtscreen((sU/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/dispatcher.pyt__init__&s		cCs
|jjƒS(N(Rtkeys(R((sU/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/dispatcher.pytsupported_priorities3sc	CsÌ|j|ƒ\}}}|tkr>tjtdƒ|ƒdSx„|jj|gƒD]m\}}|rœ|j|d|d|d|d|dƒrœqTn|j||ƒ}|t	j
krT|SqTWt	jS(sKDispatch notification messages to the appropriate endpoint method.
        sUnknown priority "%s"Ntctxttpublisher_idt
event_typetmetadatatpayload(t_extract_user_messageRtLOGtwarningRRtgettmatcht_exec_callbackR
RR(Rtincomingtprioritytraw_messagetmessageR#tcallbacktret((sU/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/dispatcher.pytdispatch7s cCsWy.||d|d|d|d|dƒSWn"tk
rRtjdƒtjSXdS(NR'R(R)R+R*sCallback raised an exception.(t	ExceptionR-t	exceptionR
R(RR6R5((sU/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/dispatcher.pyR1Ns


c	
CsÆ|jj|jƒ}|j}|jdƒ}|jdƒ}i|jdƒd6|jdƒd6}|jddƒjƒ}|jj||jdƒƒ}||td|d|d|d|d	|ƒfS(
NR(R)t
message_idt	timestampR3tR+R'R*(Rtdeserialize_contextR'R5R/tlowertdeserialize_entitytdict(	RR2R'R5R(R)R*R3R+((sU/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/dispatcher.pyR,Ys	(R
RR$tpropertyR&R8R1R,(((sU/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/dispatcher.pyR%s
	
		tBatchNotificationDispatchercBs eZdZd„Zd„ZRS(s A message dispatcher which understands Notification messages.

    A MessageHandlingServer is constructed by passing a callable dispatcher
    which is invoked with a list of message dictionaries each time 'batch_size'
    messages are received or 'batch_timeout' seconds is reached.
    c
s_tj‡fd†|Dƒd„ƒ}tƒ}x*|D]"\}}tjj|Œ\}}}t|ƒ}t|ƒ}|tkrœtj	t
dƒ|ƒq5nx¸ˆjj|gƒD]¡\}}	|rg|D];}
|j
|
d|
d|
d|
d|
dƒrË|
^qË}n|}|s!q²nˆj|	|ƒ}|tjkr²|j|ƒPq²q²Wq5W|S(	sKDispatch notification messages to the appropriate endpoint method.
        c3s|]}ˆj|ƒVqdS(N(R,(t.0tm(R(sU/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/dispatcher.pys	<genexpr>zscSs|dS(Ni((tx((sU/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/dispatcher.pyt<lambda>{ssUnknown priority "%s"R'R(R)R*R+(RtgroupbytsettsixtmovestziptlistRR-R.RRR/R0R1R
Rtupdate(
RR2tmessages_groupedtrequeuesR3tmessagest__traw_messagesR#R6R5tfiltered_messagesR7((RsU/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/dispatcher.pyR8us:	

cCs7y||ƒSWn"tk
r2tjdƒtjSXdS(NsCallback raised an exception.(R9R-R:R
R(RR6RQ((sU/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/dispatcher.pyR1›s


(R
Rt__doc__R8R1(((sU/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/dispatcher.pyRCms	&(RtloggingRJtoslo_messaging._i18nRtoslo_messagingRRRt	getLoggerR
R-RtobjectR
tDispatcherBaseRRC(((sU/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/dispatcher.pyt<module>sH

Products

About

Resources

Contact Gemfury