diff --git a/intelmq/bots/outputs/amqptopic/output.py b/intelmq/bots/outputs/amqptopic/output.py
index 52e70cd01..572a678f6 100644
--- a/intelmq/bots/outputs/amqptopic/output.py
+++ b/intelmq/bots/outputs/amqptopic/output.py
@@ -41,8 +41,8 @@ def init(self):
         self.connection_port = self.parameters.connection_port
         self.connection_vhost = self.parameters.connection_vhost
         if self.parameters.username and self.parameters.password:
-            self.kwargs['credentials'] = pika.PlainCredentials(self.username,
-                                                               self.password)
+            self.kwargs['credentials'] = pika.PlainCredentials(self.parameters.username,
+                                                               self.parameters.password)
         self.connection_parameters = pika.ConnectionParameters(
             host=self.connection_host,
             port=self.connection_port,