Mehdi Abaakouk 7e71ac821f rabbit: make ack/requeue thread-safe
ack/requeue messages are currently done in the
MessageHandlingServer._process_incoming().

But _process_incoming() in run by a futurist Executor.
That can be a threading or an eventlet executor.

With eventlet, we don't really share the socket between threads.

But with threading executor and expecialy ssl, this can't work, if you
write data with two different threads to the socket.

This change moves back the message ack/requeue to the polling threads
that handle the connection, instead of the threads we spawn for the
application.

Oslo Messaging now always use a connection in the same thread.

Change-Id: I5c0e6def6b34f4d195fb1f8dbb26eda0f21ff34e
2017-02-22 18:39:53 +01:00
2017-02-20 20:09:48 +00:00
2015-09-24 18:11:22 +08:00
2017-01-20 19:15:37 +00:00
2017-02-10 13:21:22 +00:00
2014-06-05 22:48:44 +02:00
2017-01-02 11:34:02 +01:00
2016-11-25 13:19:49 +01:00
2017-01-13 18:13:32 +00:00
2015-09-17 12:16:04 +00:00
2017-02-10 13:21:22 +00:00

Team and repository tags

image

Oslo Messaging Library

Latest Version

Downloads

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

Description
OpenStack library for messaging
Readme 36 MiB
Languages
Python 99.8%
Shell 0.2%