ó
čEYc@s€dZd
dl
Z
d
dlZd
dlmZ
d
dlmZ
e
jeƒ
Z	dej
f
d„ƒYZdef
d„ƒYZdS(	s‰
Notification drivers for sending notifications via messaging.

The messaging drivers publish notification messages to notification
listeners.

The driver will block the notifier's thread until the notification message has
been passed to the messaging transport.  There is no guarantee that the
notification message will be consumed by a notification listener.

Notification messages are sent 'at-most-once' - ensuring that they are not
duplicated.

If the connection to the messaging service is not active when a notification is
sent this driver will block waiting for the connection to complete.  If the
connection fails to complete, the driver will try to re-establish that
connection. By default this will continue indefinitely until the connection
completes. However, the retry parameter can be used to have the notification
send fail with a MessageDeliveryFailure after the given number of retries.
iÿÿÿÿN(
t_LE(
tnotifiertMessagingDrivercBs#eZ
dZd
d„
Zd„ZRS(sW
Send notifications using the 1.0 message format.

    This driver sends notifications over the configured messaging transport,
    but without any message envelope (also known as message format 1.0).

    This driver should only be used in cases where there are existing consumers
    deployed which do not support the 2.0 message format.
    gð?cCs)tt
|ƒj|
||ƒ
||_dS(
N(tsuperRt__init__tversion(tselftconfttopicst	transportR((sT/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/messaging.pyR;s

c	Cs¢|jƒ}x|j
D]„}tjd
d||fƒ
}y)|jj||
|d|jd|ƒ
Wqtk
r™


tj	t
dƒ
td
|d|ƒƒ
qXqWdS(Nttopics%s.%sRtretrys=Could not send notification to %(topic)s. Payload=%(message)stmessage(tlowerRtoslo_messagingtTargetR	t_send_notificationRt	ExceptiontLOGt	exceptionRtdict(RtctxtRtpriorityRR
ttarget((sT/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/messaging.pytnotify?s





	



(t__name__t
__module__t__doc__RR(((sT/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/messaging.pyR0s	tMessagingV2Driverc
BseZ
dZd
„ZRS(s0Send notifications using the 2.0 message format.cKs#tt
|ƒj|
d
d|


dS(NRg@(RRR(RRtkwargs((sT/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/messaging.pyRQs
(RRRR(((sT/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/messaging.pyRMs(
RtloggingRtoslo_messaging._i18nRtoslo_messaging.notifyR
t	getLoggerRRtDriverRR(((sT/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/notify/messaging.pyt<module>%s