fix for amqp URL

This commit is contained in:
Sonja Happ 2020-03-20 13:16:14 +01:00
parent 4945d6ee85
commit d29a8f30f7

View file

@ -209,7 +209,7 @@ func main() {
}
// create amqp URL based on username, password and host
amqpurl := amqpuser + ":" + amqppass + "@" + amqphost
amqpurl := "amqp://" + amqpuser + ":" + amqppass + "@" + amqphost
err = connectAMQP(amqpurl, api)
if err != nil {
panic(err)