Change queue url

leapfrogtechnology · Sep 10, 2019 · 9fb9995 · 9fb9995
1 parent 2177343
commit 9fb9995
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/deployment/services/mq/mq.go b/deployment/services/mq/mq.go
@@ -12,8 +12,9 @@ func failOnError(err error, msg string) {
 	}
 }
 
-func getQueue() (*amqp.Connection, *amqp.Channel, *amqp.Queue) {
-	conn, err := amqp.Dial("amqp://shift:shiftdeveloper@localhost:5672")
+// GetConnection returns the connection to rabbitmq
+func GetConnection() *amqp.Connection {
+	conn, err := amqp.Dial("amqp://shift:shiftdeveloper@dev-shiftmq.lftechnology.com:5672")
 
 	failOnError(err, "Failed to connect to RabbitMQ")