diff options
| author | Ask Solem <ask@celeryproject.org> | 2012-03-25 15:38:26 +0100 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2012-03-25 15:38:26 +0100 |
| commit | b63ac5246a5a312bf4491ab1e9d397ce9ed246d2 (patch) | |
| tree | e6a4987e6fd4865da8db84a0383ad29ad5139917 /kombu/transport/mongodb.py | |
| parent | 9b922871d412dc8bdd2bba0dc7d7235fdbfdfd16 (diff) | |
| download | kombu-b63ac5246a5a312bf4491ab1e9d397ce9ed246d2.tar.gz | |
All transports now include StdChannelError in its channel_errors
Diffstat (limited to 'kombu/transport/mongodb.py')
| -rw-r--r-- | kombu/transport/mongodb.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/kombu/transport/mongodb.py b/kombu/transport/mongodb.py index 7f0891a7..be80efd8 100644 --- a/kombu/transport/mongodb.py +++ b/kombu/transport/mongodb.py @@ -19,6 +19,7 @@ from anyjson import loads, dumps from pymongo.connection import Connection from . import virtual +from ..exceptions import StdChannelError DEFAULT_HOST = "127.0.0.1" DEFAULT_PORT = 27017 @@ -178,5 +179,6 @@ class Transport(virtual.Transport): polling_interval = 1 default_port = DEFAULT_PORT connection_errors = (errors.ConnectionFailure, ) - channel_errors = (errors.ConnectionFailure, + channel_errors = (StdChannelError, + errors.ConnectionFailure, errors.OperationFailure, ) |