exceptions.LimitExceeded

1 files changed, 13 insertions, 6 deletions

diff --git a/kombu/exceptions.py b/kombu/exceptions.py
index 5ca2e7b9..fe88ac38 100644
--- a/kombu/exceptions.py
+++ b/kombu/exceptions.py
@@ -10,13 +10,20 @@ class EnsureExhausted(Exception):
     """ensure() limit exceeded."""
 
 
-class PoolExhausted(Exception):
-    """All connections acquired."""
+class TimeoutError(Exception):
+    """Operation timed out."""
 
 
-class PoolLimitExceeded(Exception):
-    """Can't add more connections to pool."""
+class LimitExceeded(Exception):
+    """Limit exceeded."""
+    pass
+
+
+class ConnectionLimitExceeded(LimitExceeded):
+    """Maximum number of simultaneous connections exceeded."""
+    pass
 
-class TimeoutError(Exception):
-    """Operation timed out."""
 
+class ChannelLimitExceeded(LimitExceeded):
+    """Maximum number of simultaenous channels exceeded."""
+    pass