diff options
author | Zuul <zuul@review.opendev.org> | 2022-01-12 15:29:41 +0000 |
---|---|---|
committer | Gerrit Code Review <review@openstack.org> | 2022-01-12 15:29:41 +0000 |
commit | 5d165cc713a98dbd650e9e6295d7966ce2919935 (patch) | |
tree | 76dd1a861889d047608ffee7ca19ac918c6c8977 /oslo_messaging/_drivers/pool.py | |
parent | 5eeccdd425a7ddbeffe2ee9a97458da65bb1d82c (diff) | |
parent | 7b3968d9b012e873a9b393fcefa578c46fca18c6 (diff) | |
download | oslo-messaging-5d165cc713a98dbd650e9e6295d7966ce2919935.tar.gz |
Merge "[rabbit] use retry parameters during notification sending"12.12.0
Diffstat (limited to 'oslo_messaging/_drivers/pool.py')
-rw-r--r-- | oslo_messaging/_drivers/pool.py | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/oslo_messaging/_drivers/pool.py b/oslo_messaging/_drivers/pool.py index 8090e8d..9e5288d 100644 --- a/oslo_messaging/_drivers/pool.py +++ b/oslo_messaging/_drivers/pool.py @@ -69,7 +69,7 @@ class Pool(object, metaclass=abc.ABCMeta): self._items.append((ttl_watch, item)) self._cond.notify() - def get(self): + def get(self, retry=None): """Return an item from the pool, when one is available. This may cause the calling thread to block. @@ -95,7 +95,7 @@ class Pool(object, metaclass=abc.ABCMeta): # We've grabbed a slot and dropped the lock, now do the creation try: - return self.create() + return self.create(retry=retry) except Exception: with self._cond: self._current_size -= 1 @@ -111,7 +111,7 @@ class Pool(object, metaclass=abc.ABCMeta): return @abc.abstractmethod - def create(self): + def create(self, retry=None): """Construct a new item.""" @@ -130,9 +130,9 @@ class ConnectionPool(Pool): LOG.debug("Idle connection has expired and been closed." " Pool size: %d" % len(self._items)) - def create(self, purpose=common.PURPOSE_SEND): + def create(self, purpose=common.PURPOSE_SEND, retry=None): LOG.debug('Pool creating new connection') - return self.connection_cls(self.conf, self.url, purpose) + return self.connection_cls(self.conf, self.url, purpose, retry=retry) def empty(self): for item in self.iter_free(): |