Merge pull request #5 from dukhlov/master

Small fix of timeout parameter usage
2015-11-23 11:58:09 -08:00
parent e47facbacc 3e1c38ed11
commit 146bbd1cbb
1 changed files with 1 additions and 1 deletions
--- a/pika_pool.py
+++ b/pika_pool.py
@@ -307,7 +307,7 @@ class QueuedPool(Pool):
            except Overflow:
                timeout = timeout or self.timeout
                try:
-                    fairy = self._queue.get(timeout=self.timeout)
+                    fairy = self._queue.get(timeout=timeout)
                except queue.Empty:
                    try:
                        fairy = self._create()