commit a8a6ab0264e195d25d5b87691877e9e6006f1c61
author Dean Troyer <dtroyer@gmail.com> Fri Nov 04 16:46:11 2011 +0000
committer Dean Troyer <dtroyer@gmail.com> Thu Nov 10 16:29:20 2011 -0600
tree ed9a283f81b39c2dbb1355f190d9d195118ba362
parent cc0fb757d6d75779a4bf67c6ba51b05d5cdae9a4

Fix rabbitmq login

Change-Id: Ic0044adec32ac2cabff7aefe4d11970224ff1cd0

kong/tests/994_test_rabbitmq.py

diff --git a/kong/tests/994_test_rabbitmq.py b/kong/tests/994_test_rabbitmq.py
index 0a10194..77d30a0 100644
--- a/kong/tests/994_test_rabbitmq.py
+++ b/kong/tests/994_test_rabbitmq.py
@@ -41,11 +41,10 @@
     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)