oslo.messaging/oslo_messaging/_drivers
Arnaud Morin fd2381c723 Disable greenthreads for RabbitDriver "listen" connections
When enabling heartbeat_in_pthread, we were restoring the "threading"
python library from eventlet to original one in RabbitDriver but we
forgot to do the same in AMQPDriverBase (RabbitDriver is subclass of
AMQPDriverBase).

We also need to use the original "queue" so that queues are not going to
use greenthreads as well.

Related-bug: #1961402
Related-bug: #1934937
Closes-bug: #2009138

Signed-off-by: Arnaud Morin <arnaud.morin@ovhcloud.com>
Change-Id: I34ea0d1381e934297df2f793e0d2594ef8254f00
2023-03-03 11:24:27 +01:00
..
amqp1_driver amqp1: fix race when reconnecting 2021-11-09 15:59:54 -05:00
kafka_driver Add support for kafka SSL autentication 2020-01-16 23:26:53 +01:00
__init__.py Fixed a couple of pep8 errors/warnings 2016-01-25 15:00:49 +08:00
amqp.py Adding support for rabbitmq quorum queues 2022-02-05 07:12:49 +00:00
amqpdriver.py [rabbit] use retry parameters during notification sending 2022-01-12 12:22:55 +01:00
base.py add min of 1 to rpc_conn_pool_size 2020-10-13 12:44:30 +01:00
common.py [rabbit] use retry parameters during notification sending 2022-01-12 12:22:55 +01:00
impl_amqp1.py Add the "transport_options" parameter to the amqp1 and kafka drivers. 2019-06-20 16:12:39 -04:00
impl_fake.py Remove six usage 2020-05-11 10:21:58 +02:00
impl_kafka.py Remove logging from ProducerConnection._produce_message 2022-08-03 17:35:16 +02:00
impl_rabbit.py Disable greenthreads for RabbitDriver "listen" connections 2023-03-03 11:24:27 +01:00
pool.py [rabbit] use retry parameters during notification sending 2022-01-12 12:22:55 +01:00