openstack
/
oslo.messaging
Code Issues Proposed changes
2,811 Commits 12 Branches 52 Tags 35 MiB
Commit Graph

13 Commits

Author SHA1 Message Date
Doug Hellmann 03265410e0 Remove oslo namespace package 
Blueprint remove-namespace-packages

Depends-on: I2eeef93ee2e61a721c69f62add819f93f62f077d
for openstack/ceilometer
Depends-on: I26390dd908769be5f1a5b70be22d3b98e3a45563
for openstack/ceilometermiddleware
Depends-on: Ifa8baab33cdb3e606cf175a8c29c3a4ef6c44480
for openstack/glance
Depends-on: I029c3260051aa48cfaae428c096c1ac7b43b2bd2
for openstack/ceilometermiddleware

Change-Id: I8c5595bbafa82db33f62fa47d214f5cb756a2639
 2015-07-16 17:47:16 +00:00
Doug Hellmann e55a83e832 Move files out of the namespace package 
Move the public API out of oslo.messaging to oslo_messaging. Retain
the ability to import from the old namespace package for backwards
compatibility for this release cycle.

bp/drop-namespace-packages

Co-authored-by: Mehdi Abaakouk <mehdi.abaakouk@enovance.com>
Change-Id: Ia562010c152a214f1c0fed767c82022c7c2c52e7
 2015-01-12 12:50:41 -05:00
Victor Stinner 0844037fad Add an optional executor callback to dispatcher 
The callback will be used in the new aiogreen executor to support
trollius coroutines.

The change includes an unit test.

Change-Id: I556b112371bec2ec29cea4dc254bb3f9c6d2c07a
 2014-12-03 01:45:17 +01:00
Mehdi Abaakouk 30e0aea877 Notification listener pools 
We can now set the pool name of a notification listener
to create multiple groups/pools of listeners consuming notifications
and that each group/pool only receives one copy of each notification.

The AMQP implementation of that is to set queue_name with the pool name.

Implements blueprint notification-listener-pools
Closes-bug: #1356226

Change-Id: I8dc0549f5550f684a261c78c58737b798fcdd656
 2014-11-14 10:20:18 +01:00
Christian Berendt 8151da821b Enable PEP8 check E241 
* E241 multiple spaces after ':'

Change-Id: I2310ffc00b7fe58d0781705a73212eefa116c999
 2014-08-08 06:06:55 +00:00
Christian Berendt 409108c74f replace string format arguments with function parameters 
There are files containing string format arguments inside
logging messages. Using logging function parameters should
be preferred.

Change-Id: I4a7ce6916aefb2f2d445f0ebd977c824b1c51e24
Partial-Bug: #1321274
 2014-06-20 14:18:40 +01:00
Jenkins 8cccf06c65 Merge "notification listener: add allow_requeue param" 2014-03-03 20:49:54 +00:00
Mehdi Abaakouk ed2a1545c0 Add missing data into the notif. endpoint callback 
Some information about the notification (ie: message_id and timestamp)
are currently not available for the application.

This change add them.

Partial implements blueprint notification-subscriber-server

Change-Id: I83e562725205fb270f6065fe1118c3c9865b2294
 2014-03-03 17:33:41 +01:00
Mark McLoughlin 5bd31315c2 notification listener: add allow_requeue param 
In commit d8d2ad9 we added support for notification listener endpoint
methods to return REQUEUE, but if a driver does not support this we
raise NotImplementedError when the application attempts to requeue
a message.

This requeuing behaviour might only be used by an application in
unusual, exceptional circumstances and catch users by surprise.

Instead, let's require the application to assert that it needs this
feature in advance and raise NotImplementError at that point if the
driver doesn't support it.

Change-Id: Id0bb0e57d2dcc1ec7d752e98c9b1e8e48d99f35c
 2014-03-03 07:51:18 -08:00
Mehdi Abaakouk d8d2ad95d7 Allow to requeue the notification message 
This patch allow to requeue the notification received by the
notification listener.

Partial implements blueprint notification-subscriber-server

Change-Id: I49c4ba91224c280e479edb19289ccb337a2ab843
 2014-03-03 09:27:57 +01:00
Mehdi Abaakouk e785a5d994 Make the dispatcher responsible of the message ack 
This patch make the dispatcher responsible of the message
acknowledgement.

This is the preliminar step to be able to requeue message.

Partial implements blueprint notification-subscriber-server

Change-Id: If74b47d5e23976d407deb27df7395b1982963c75
 2014-02-18 08:31:30 +01:00
Mehdi Abaakouk 8a644c1166 Don't reply to notification message 
The notification listener doesn't have anything to send to the notifier
and the notifier doesn't attend to receive something.

So this patch remove the message reply when the listener is a
notification
listener.

Partial implements blueprint notification-subscriber-server

Change-Id: Ic989947ba3b6894cde788422842fca19159ea261
 2014-02-18 08:31:30 +01:00
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