diff options
| author | Russell Bryant <rbryant@redhat.com> | 2012-12-13 12:53:43 -0500 |
|---|---|---|
| committer | Russell Bryant <rbryant@redhat.com> | 2013-01-03 14:02:09 -0500 |
| commit | adffcd58fb09dafb0c4e128797b4a61a59087f9a (patch) | |
| tree | afcbabee9561afb0fbc56ef2dafe6288c107ca01 /openstack/common/rpc/impl_qpid.py | |
| parent | fdc74c07d63ff897f42405b6dde0ffa46d6e26c3 (diff) | |
| download | oslo-adffcd58fb09dafb0c4e128797b4a61a59087f9a.tar.gz oslo-adffcd58fb09dafb0c4e128797b4a61a59087f9a.tar.xz oslo-adffcd58fb09dafb0c4e128797b4a61a59087f9a.zip | |
Optionally add message envelope to notifications.
When message envelopes were added for rpc messages, notifications were
explicitly left out. This was due to the fact that notifications are
consumed outside of OpenStack. However, notification consumers will
likely want to eventually start taking advantage of some of the features
that the envelope is a prerequisite for, such as message signing.
This patch adds a new notification driver that produces message based
notifications including the message envelope.
Related to blueprint version-rpc-messages.
Change-Id: Iaa8b437e6b4f64053f4b02bf486516f60bb020e9
Diffstat (limited to 'openstack/common/rpc/impl_qpid.py')
| -rw-r--r-- | openstack/common/rpc/impl_qpid.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/openstack/common/rpc/impl_qpid.py b/openstack/common/rpc/impl_qpid.py index a6dd983..d42fe16 100644 --- a/openstack/common/rpc/impl_qpid.py +++ b/openstack/common/rpc/impl_qpid.py @@ -583,10 +583,11 @@ def fanout_cast_to_server(conf, context, server_params, topic, msg): rpc_amqp.get_connection_pool(conf, Connection)) -def notify(conf, context, topic, msg): +def notify(conf, context, topic, msg, envelope): """Sends a notification event on a topic.""" return rpc_amqp.notify(conf, context, topic, msg, - rpc_amqp.get_connection_pool(conf, Connection)) + rpc_amqp.get_connection_pool(conf, Connection), + envelope) def cleanup(): |