summaryrefslogtreecommitdiff
path: root/kombu/transport/pyamqplib.py
diff options
context:
space:
mode:
authorAsk Solem <ask@celeryproject.org>2011-04-01 14:25:53 +0200
committerAsk Solem <ask@celeryproject.org>2011-04-01 14:26:39 +0200
commitd9351e8eaffda0ea9b2b5031ab87b04a6b272754 (patch)
treee89aff8c8c00a07b19149ac8d836c31c4893e6b7 /kombu/transport/pyamqplib.py
parent47e6709f702c53f27cb04e0ca73844dd5129a83d (diff)
downloadkombu-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.py4
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,