Kenneth Giusti 26b0be585a Issue blocking ACK for RPC requests from the consumer thread ... The patch for https://review.openstack.org/#/c/436958/ fixed a threading problem by moving the ack back to the polling thread. However the RPC server expects to catch any failures of the ACK and abort the request. This patch adds the ACK error handling back to the polling thread. This patch is based heavily off the original work done by Mehdi Abaakouk (sileht). Change-Id: I708c3d6676b974d8daac6817c15f596cdf35817b Closes-Bug: #1695746		2018-07-11 08:59:35 -04:00
..
amqp1_driver	Merge "Fix the bandit security linter test"	2018-07-04 18:04:50 +00:00
kafka_driver	Add kafka config options for security (ssl/sasl)	2018-02-13 09:17:06 -05:00
zmq_driver	py37: drop use of 'async' as parameter name	2018-07-05 06:09:37 -05:00
__init__.py	Fixed a couple of pep8 errors/warnings	2016-01-25 15:00:49 +08:00
amqp.py	[rabbitmq] Implement active call monitoring	2018-05-09 10:08:37 -07:00
amqpdriver.py	Issue blocking ACK for RPC requests from the consumer thread	2018-07-11 08:59:35 -04:00
base.py	[rabbitmq] Implement active call monitoring	2018-05-09 10:08:37 -07:00
common.py	Fix debug log message - missing argument	2018-07-06 11:41:07 -04:00
impl_amqp1.py	Enable RPC call monitoring in AMQP 1.0 driver	2018-06-13 11:01:38 -04:00
impl_fake.py	[rabbitmq] Implement active call monitoring	2018-05-09 10:08:37 -07:00
impl_kafka.py	[rabbitmq] Implement active call monitoring	2018-05-09 10:08:37 -07:00
impl_rabbit.py	Do not access the connection's socket during error callback	2018-07-06 12:15:53 -04:00
impl_zmq.py	Mark the ZeroMQ driver deprecated	2018-06-11 15:11:31 -04:00
pool.py	Replace 'raise StopIteration' with 'return'	2018-06-29 14:39:46 +01:00