init consumer

Author: damasdev

cmd/consumer/main.go

@@ -1,8 +1,11 @@
 package main
 
 import (
-	userConsumer "go-hexagonal-architecture/internal/infrastructure/messaging/rabbitmq/user"
+	"context"
+	"go-hexagonal-architecture/internal/interfaces/pubsub/consumer"
+	userHandler "go-hexagonal-architecture/internal/interfaces/pubsub/handler/user"
 	"go-hexagonal-architecture/pkg/config"
+
 	"log"
 )
 
@@ -12,10 +15,15 @@ func init() {
 }
 
 func main() {
-	userConsumer := userConsumer.NewConsumer(config.RabbitConn)
 
-	err := userConsumer.StartConsumer(1, "user-exchange", "user-queue", "user-key", "user-tag")
-	if err != nil {
+	userHandler := userHandler.New()
+
+	consumer := consumer.New(config.RabbitConn)
+
+	consumer.RegisterHandler("user-exchange", "user-queue-hello", "user-key-hello", "user-tag-hello", userHandler.Hello)
+	consumer.RegisterHandler("user-exchange", "user-queue-world", "user-key-world", "user-tag-world", userHandler.World)
+
+	if err := consumer.Start(context.Background()); err != nil {
 		log.Fatal(err.Error())
 	}
 }

internal/core/port/user/messaging.go

@@ -0,0 +1,47 @@
+package consumer
+
+type Config struct {
+	exchangeKind       string
+	exchangeDurable    bool
+	exchangeAutoDelete bool
+	exchangeInternal   bool
+	exchangeNoWait     bool
+
+	queueDurable    bool
+	queueAutoDelete bool
+	queueExclusive  bool
+	queueNoWait     bool
+
+	prefetchCount  int
+	prefetchSize   int
+	prefetchGlobal bool
+
+	consumeAutoAck   bool
+	consumeExclusive bool
+	consumeNoLocal   bool
+	consumeNoWait    bool
+}
+
+func LoadDefaultConfig() Config {
+	return Config{
+		exchangeKind:       "direct",
+		exchangeDurable:    true,
+		exchangeAutoDelete: false,
+		exchangeInternal:   false,
+		exchangeNoWait:     false,
+
+		queueDurable:    true,
+		queueAutoDelete: false,
+		queueExclusive:  false,
+		queueNoWait:     false,
+
+		prefetchCount:  1,
+		prefetchSize:   0,
+		prefetchGlobal: false,
+
+		consumeAutoAck:   false,
+		consumeExclusive: false,
+		consumeNoLocal:   false,
+		consumeNoWait:    false,
+	}
+}