Fixed issues

redis-http-connector/main.go

@@ -107,7 +107,10 @@ func main() {
 	}
 	defer logger.Sync()
 
-	connectordata, _ := common.ParseConnectorMetadata()
+	connectordata, err := common.ParseConnectorMetadata()
+	if err != nil {
+		logger.Error("Error while parsing connector metadata", zap.Error(err))
+	}
 
 	address := os.Getenv("ADDRESS")
 	if address == "" {

redis-http-connector/test/consumer/consume_messages.go

@@ -4,30 +4,32 @@ import (
 	"context"
 	"fmt"
 	"log"
+	"os"
 
 	"github.com/go-redis/redis/v8"
 )
 
 func main() {
 
-	/*address := os.Getenv("REDIS_ADDRESS")
+	address := os.Getenv("REDIS_ADDRESS")
 	if address == "" {
 		log.Fatalf("Empty address field")
 	}
-	password := os.Getenv("REDIS_PASSWORD")*/
-	address := "127.0.0.1:6379"
-	password := ""
+	password := os.Getenv("REDIS_PASSWORD")
 
 	var ctx = context.Background()
-	var i int64
+	var listItr int64
 	rdb := redis.NewClient(&redis.Options{
 		Addr:     address,
 		Password: password,
 	})
 
-	list_len, err := rdb.LLen(ctx, "response-topic").Result()
+	listLength, err := rdb.LLen(ctx, "response-topic").Result()
+	if err != nil {
+		log.Fatalf("Error in consuming queue: %v", err)
+	}
 
-	for i = 0; i < list_len; i++ {
+	for listItr = 0; listItr < listLength; listItr++ {
 		msg, err := rdb.LPop(ctx, "response-topic").Result()
 
 		if err != nil {