diff --git a/stacktach/message_service.py b/stacktach/message_service.py
index 0208f29..cd0cef6 100644
--- a/stacktach/message_service.py
+++ b/stacktach/message_service.py
@@ -19,7 +19,7 @@ def create_exchange(name, exchange_type, exclusive=False, auto_delete=False,
 def create_connection(hostname, port, userid, password, transport,
                       virtual_host):
     return kombu.connection.BrokerConnection(
-        hostname=hostname, port=port, user_id=userid, password=password,
+        hostname=hostname, port=port, userid=userid, password=password,
         transport=transport, virtual_host=virtual_host)