Allow connection pools with no limit

2010-11-30 19:56:12 +01:00 · 2010-11-30 19:56:12 +01:00 · a574515aa9
parent c86ced6746
commit a574515aa9
1 changed files with 6 additions and 5 deletions
--- a/kombu/connection.py
+++ b/kombu/connection.py
@ -474,6 +474,7 @@ class ConnectionPool(Resource):
        return copy(self.connection)

    def setup(self):
+        if self.limit:
            for i in xrange(self.limit):
                conn = self.new()
                if i < self.preload: