Vladimir Kozhukalov 930d97599c [rabbit] Ignore stream offset header when stream queue is not used ... Consumer callback should look for x-stream-offset header only if the stream mode is used. Otherwise the message headers attribute could be None and the error appears when using get method. Closes-Bug: #2084168 Change-Id: I7f9c742f8f557d9faae2cd749d34dcb15d8005c0		2024-10-14 15:43:22 +09: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	Fix queue_manager in a containerized environment	2024-09-17 22:30:21 +09:00
base.py	Add RPC incoming and reply log	2024-07-12 18:40:11 +09:00
common.py	[rabbit] use retry parameters during notification sending	2022-01-12 12:22:55 +01:00
impl_amqp1.py	Deprecate the amqp1 driver and Remove qpid functional tests	2022-10-18 11:27:46 +02:00
impl_fake.py	Fix clearing of the fake RPC Exchange	2023-11-15 12:26:47 +01:00
impl_kafka.py	Use oslo.utils implementation to parse/escape server address	2024-10-06 01:11:08 +09:00
impl_rabbit.py	[rabbit] Ignore stream offset header when stream queue is not used	2024-10-14 15:43:22 +09:00
pool.py	[rabbit] use retry parameters during notification sending	2022-01-12 12:22:55 +01:00