Merge pull request #72 from /issues/68

#68 | Kafka or Rabbitmq to be optional to use Clamp

Author: lohith46

.circleci/config.yml

@@ -65,6 +65,8 @@ jobs:
             CLAMP_DB_CONNECTION_STR: "host=localhost:5432 user=clamptest dbname=clamptest"
             CLAMP_KAFKA_CONNECTION_STR: "localhost:9092"
             CLAMP_QUEUE_CONNECTION_STR: "amqp://guest:guest@localhost:5672/"
+            ENABLE_KAFKA_INTEGRATION: true
+            ENABLE_AMQP_INTEGRATION: true
           command: |
             if [ $CIRCLE_BRANCH == 'master' ]; then
               ./cc-test-reporter before-build

config/env.go

@@ -45,6 +45,9 @@ var ENV = struct {
 	*/
 	PORT          string   `env:"APP_PORT" envDefault:"8080"`
 	AllowOrigins  []string `env:"ALLOW_ORIGINS" envDefault:"http://localhost:3000,http://54.149.76.62"`
+
+	EnableKafkaIntegration    bool `env:"ENABLE_KAFKA_INTEGRATION" envDefault:false`
+	EnableRabbitMQIntegration bool `env:"ENABLE_AMQP_INTEGRATION" envDefault:false`
 }{}
 
 func init() {

main.go

@@ -19,8 +19,12 @@ func main() {
 		os.Exit(0)
 	}
 
-	listeners.AmqpStepResponseListener.Listen()
-	listeners.KafkaStepResponseListener.Listen()
+	if config.ENV.EnableRabbitMQIntegration {
+		listeners.AmqpStepResponseListener.Listen()
+	}
+	if config.ENV.EnableKafkaIntegration {
+		listeners.KafkaStepResponseListener.Listen()
+	}
 	handlers.LoadHTTPRoutes()
 	log.Println("Calling listener")
 }