#68 | Correcting Enable RabbitMQ and Kakfa variable correctly in main…

….go and circle-ci file
clamp-orchestrator · Oct 28, 2020 · c8df422 · c8df422
1 parent 09c016b
commit c8df422
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/.circleci/config.yml b/.circleci/config.yml
@@ -66,7 +66,7 @@ jobs:
             CLAMP_KAFKA_CONNECTION_STR: "localhost:9092"
             CLAMP_QUEUE_CONNECTION_STR: "amqp://guest:guest@localhost:5672/"
             ENABLE_KAFKA_INTEGRATION: true
-            EnableRabbitMQIntegration: true
+            ENABLE_AMQP_INTEGRATION: true
           command: |
             if [ $CIRCLE_BRANCH == 'master' ]; then
               ./cc-test-reporter before-build

diff --git a/main.go b/main.go
@@ -19,7 +19,7 @@ func main() {
 		os.Exit(0)
 	}
 
-	if config.ENV.EnableKafkaIntegration {
+	if config.ENV.EnableRabbitMQIntegration {
 		listeners.AmqpStepResponseListener.Listen()
 	}
 	if config.ENV.EnableKafkaIntegration {