Configure pool limit using BROKER_POOL_LIMIT (default 10)

celery/app/base.py

@@ -245,7 +245,7 @@ class BaseApp(object):
                 [self.prepare_config(self.loader.conf), deepcopy(DEFAULTS)])
 
     def _set_pool(self):
-        self._pool = self.broker_connection().Pool(2)
+        self._pool = self.broker_connection().Pool(self.conf.BROKER_POOL_LIMIT)
         self._pool.owner_pid = os.getpid()
 
     def _reset_after_fork(self):

celery/app/defaults.py

@@ -50,6 +50,7 @@ NAMESPACES = {
         "CONNECTION_TIMEOUT": Option(4, type="int"),
         "CONNECTION_RETRY": Option(True, type="bool"),
         "CONNECTION_MAX_RETRIES": Option(100, type="int"),
+        "POOL_LIMIT": Option(10, type="int"),
         "INSIST": Option(False, type="bool"),
         "USE_SSL": Option(False, type="bool"),
     },