Mehdi Abaakouk 9f58e2c3fe Implements notification listener and dispatcher

This patch allows to quickly create a listener to receive
notification messages.

Example of the api:

class Endpoint(object):
    def warn(self, ctxt, publisher_id, event_type, payload):
        do_something(payload)

target = messaging.Target(topic='notifications', exchange='cinder')
listener = notify.get_notification_listener(transport, [target],
                                            [Endpoint()],
                                            executor,
                                            serializer)

Implements blueprint notification-subscriber-server

Change-Id: I434bc487c382a2048670df726d9bebd640150bb9

2014-02-14 16:06:26 +01:00

2.1 KiB

Raw Blame History

oslo.messaging

The Oslo messaging API supports RPC and notifications over a number of different messsaging transports.

transport target server rpcclient notifier notification_listener serializer exceptions opts conffixture

Release Notes

1.3.0a3

Changes since 1.3.0a2:

aliases: Add transport aliases API
1257293: Fix duplicate topic messages for Qpid topology=2
1251757: Fix issue with qpid driver reconnects
Add Sample priority to notifier API
Remove eventlet related code in amqp driver
Significant progress on Python 3 support.
Sync some changes from RPC code in oslo-incubator.

Thanks to Chang Bo Guo, Eric Guo, Ihar Hrachyshka, Joe Gordon, Kenneth Giusti, Lance Bragstad, Mehdi Abaakouk, Nikhil Manchanda, Sandy Walsh, Stanislav Kudriashev, Victor Stinner and Zhongyue Luo for their contributions to this release!

1.3.0a2

Changes since 1.3.0a1:

logging_and_notification: Notifications can now be sent using a python logging handler.
Notifier.warning() was added as an alias of Notifier.warn().
Notifier.audit() has been added.
1178375: Support a new qpid topology.
TransportURL.hosts is no longer a read-only property.
MessagingException now behaves more like normal exceptions.
Fix sending of notifications.
Many internal cleanups.

Thanks to Chang Bo Guo, Christian Strack, Julien Danjou, Kenneth Giusti and Russell Bryant for their contributions to this release!

1.2.0a1

Initial release of oslo.messaging.

Indices and tables

genindex
modindex
search

2.1 KiB Raw Blame History