diff --git a/services/fission-rmq-connector/main.go b/services/fission-rmq-connector/main.go
index 1793caf4..2a4c1a09 100644
--- a/services/fission-rmq-connector/main.go
+++ b/services/fission-rmq-connector/main.go
@@ -43,7 +43,7 @@ func main() {
 }
 
 var (
-	AMQP_HOST     = env.Must("HOST")
+	AMQP_HOST     = env.Must("AMQP_HOST")
 	AMQP_QUEUE    = env.Must("QUEUE_NAME")
 	AMQP_TOPIC    = env.Must("TOPIC")
 	AMQP_PREFETCH = env.Could("AMQP_PREFETCH", "5")