changed main.go back to original

cmd/query-service/main.go

@@ -6,6 +6,7 @@ import (
 	"log"
 	"query-service/internal/aql"
 	"query-service/internal/errorhandler"
+	"query-service/internal/messagequeue"
 	"query-service/internal/redisclient"
 
 	"query-service/internal/request"
@@ -17,22 +18,17 @@ import (
 var producer alice.Producer
 
 func main() {
-	// exchangeID := "query-requests"
-	// routingKey := "aql-user-request"
+	exchangeID := "query-requests"
+	routingKey := "aql-user-request"
 
-	// broker := messagequeue.Create()
-	// messagequeue.StartConsumer(broker, &exchangeID, &routingKey, onMessageReceived)
+	broker := messagequeue.Create()
+	messagequeue.StartConsumer(broker, &exchangeID, &routingKey, onMessageReceived)
 
-	// producer = messagequeue.StartProducer(broker)
+	producer = messagequeue.StartProducer(broker)
 
-	// redisclient.Start()
-	msg := []byte(`{"Return":{"Entities":[0],"Relations":[0]},"Entities":[{"Type":"Airport","Constraints":[{"Attribute":"month","Value":"8","DataType":"text","MatchType":"exact"}]}],"Relations":[{"Type":"Flight","Depth":{"min":1,"max":3},"EntityFrom":0,"EntityTo":-1,"Constraints":[]}]}`)
-	aqlQuery, _ := aql.ConvertJSONToAQL(&msg)
-
-	fmt.Println(*aqlQuery)
-
-	// select {}
+	redisclient.Start()
 
+	select {}
 }
 
 func onMessageReceived(msg amqp.Delivery) {