diff options
author | Ask Solem <ask@celeryproject.org> | 2011-04-01 14:25:53 +0200 |
---|---|---|
committer | Ask Solem <ask@celeryproject.org> | 2011-04-01 14:26:39 +0200 |
commit | d9351e8eaffda0ea9b2b5031ab87b04a6b272754 (patch) | |
tree | e89aff8c8c00a07b19149ac8d836c31c4893e6b7 /kombu/transport/pyamqplib.py | |
parent | 47e6709f702c53f27cb04e0ca73844dd5129a83d (diff) | |
download | kombu-d9351e8eaffda0ea9b2b5031ab87b04a6b272754.tar.gz |
BrokerConnection userid/password can't be guest as other transports may have not that default, so move this to the pika/amqplib transports.
Diffstat (limited to 'kombu/transport/pyamqplib.py')
-rw-r--r-- | kombu/transport/pyamqplib.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kombu/transport/pyamqplib.py b/kombu/transport/pyamqplib.py index e8660375..790b6c5b 100644 --- a/kombu/transport/pyamqplib.py +++ b/kombu/transport/pyamqplib.py @@ -205,9 +205,9 @@ class Transport(base.Transport): if not conninfo.hostname: raise KeyError("Missing hostname for AMQP connection.") if conninfo.userid is None: - raise KeyError("Missing user id for AMQP connection.") + conninfo.userid = "guest" if conninfo.password is None: - raise KeyError("Missing password for AMQP connection.") + conninfo.password = "guest" if not conninfo.port: conninfo.port = self.default_port conn = self.Connection(host=conninfo.host, |