Fix rabbitmq login

Change-Id: Ic0044adec32ac2cabff7aefe4d11970224ff1cd0
This commit is contained in:
Dean Troyer 2011-11-04 16:46:11 +00:00
parent cc0fb757d6
commit a8a6ab0264

View File

@ -41,11 +41,10 @@ class TestRabbitMQ(tests.FunctionalTest):
test_000_ghetto.tags = ['rabbitmq']
def _cnx(self):
# TODO: Figuring out what's going with creds
# creds = pika.credentials.PlainCredentials(
# self.rabbitmq['user'], self.rabbitmq['pass']
creds = pika.credentials.PlainCredentials(
self.rabbitmq['user'], self.rabbitmq['pass'])
connection = pika.BlockingConnection(pika.ConnectionParameters(
host=self.rabbitmq['host']))
host=self.rabbitmq['host'],credentials=creds))
channel = connection.channel()
return (channel, connection)