summaryrefslogtreecommitdiff
path: root/oslo_messaging/_drivers/amqpdriver.py
diff options
context:
space:
mode:
authorZuul <zuul@review.opendev.org>2022-01-12 15:29:41 +0000
committerGerrit Code Review <review@openstack.org>2022-01-12 15:29:41 +0000
commit5d165cc713a98dbd650e9e6295d7966ce2919935 (patch)
tree76dd1a861889d047608ffee7ca19ac918c6c8977 /oslo_messaging/_drivers/amqpdriver.py
parent5eeccdd425a7ddbeffe2ee9a97458da65bb1d82c (diff)
parent7b3968d9b012e873a9b393fcefa578c46fca18c6 (diff)
downloadoslo-messaging-5d165cc713a98dbd650e9e6295d7966ce2919935.tar.gz
Merge "[rabbit] use retry parameters during notification sending"12.12.0
Diffstat (limited to 'oslo_messaging/_drivers/amqpdriver.py')
-rw-r--r--oslo_messaging/_drivers/amqpdriver.py7
1 files changed, 4 insertions, 3 deletions
diff --git a/oslo_messaging/_drivers/amqpdriver.py b/oslo_messaging/_drivers/amqpdriver.py
index 24fdbc7..991bf46 100644
--- a/oslo_messaging/_drivers/amqpdriver.py
+++ b/oslo_messaging/_drivers/amqpdriver.py
@@ -601,9 +601,10 @@ class AMQPDriverBase(base.BaseDriver):
def _get_exchange(self, target):
return target.exchange or self._default_exchange
- def _get_connection(self, purpose=rpc_common.PURPOSE_SEND):
+ def _get_connection(self, purpose=rpc_common.PURPOSE_SEND, retry=None):
return rpc_common.ConnectionContext(self._connection_pool,
- purpose=purpose)
+ purpose=purpose,
+ retry=retry)
def _get_reply_q(self):
with self._reply_q_lock:
@@ -649,7 +650,7 @@ class AMQPDriverBase(base.BaseDriver):
log_msg = "CAST unique_id: %s " % unique_id
try:
- with self._get_connection(rpc_common.PURPOSE_SEND) as conn:
+ with self._get_connection(rpc_common.PURPOSE_SEND, retry) as conn:
if notify:
exchange = self._get_exchange(target)
LOG.debug(log_msg + "NOTIFY exchange '%(exchange)s'"