diff options
| author | Ask Solem <ask@celeryproject.org> | 2012-11-05 14:04:08 +0000 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2012-11-05 14:06:20 +0000 |
| commit | 9140a4e1a36b293717852efa9f3bd84715060642 (patch) | |
| tree | e77008106a71faced3fcc8d9a755ef3aa409f832 /kombu/transport/librabbitmq.py | |
| parent | 2afe3fb9966f258efbca789654f90f2db5834ce9 (diff) | |
| download | kombu-9140a4e1a36b293717852efa9f3bd84715060642.tar.gz | |
Ensure/Autoretry no longer disconnects on channel_errors, and adds StdConnectionError
Diffstat (limited to 'kombu/transport/librabbitmq.py')
| -rw-r--r-- | kombu/transport/librabbitmq.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/kombu/transport/librabbitmq.py b/kombu/transport/librabbitmq.py index a3be2d3c..7578c55a 100644 --- a/kombu/transport/librabbitmq.py +++ b/kombu/transport/librabbitmq.py @@ -24,7 +24,7 @@ except ImportError: except ImportError: raise ImportError("No module named librabbitmq") -from kombu.exceptions import StdChannelError +from kombu.exceptions import StdConnectionError, StdChannelError from kombu.utils.amq_manager import get_manager from . import base @@ -69,7 +69,8 @@ class Transport(base.Transport): Connection = Connection default_port = DEFAULT_PORT - connection_errors = (ConnectionError, + connection_errors = (StdConnectionError, + ConnectionError, socket.error, IOError, OSError) |