some refactoring

mehdihadeli · Sep 26, 2022 · 4c4ede2 · 4c4ede2
1 parent 054cae0
commit 4c4ede2
Show file tree

Hide file tree

Showing 5 changed files with 18 additions and 6 deletions.
diff --git a/.gitignore b/.gitignore
@@ -42,4 +42,16 @@ go.work
 .DS_Store
 
 profile.out
-coverage.txt
+coverage.txt
+.vscode/*
+!.vscode/settings.json
+!.vscode/tasks.json
+!.vscode/launch.json
+!.vscode/extensions.json
+!.vscode/*.code-snippets
+
+# Local History for Visual Studio Code
+.history/
+
+# Built Visual Studio Code Extensions
+*.vsix
diff --git a/pkg/rabbitmq/bus/rabbitmq-bus.go b/pkg/rabbitmq/bus/rabbitmq-bus.go
@@ -15,7 +15,7 @@ type rabbitMQBus struct {
 	logger    logger.Logger
 }
 
-func NewRabbitMQBus(log logger.Logger, consumers []consumer.Consumer) bus.Bus {
+func NewRabbitMQBus(log logger.Logger, consumers ...consumer.Consumer) bus.Bus {
 	return &rabbitMQBus{logger: log, consumers: consumers}
 }
 

diff --git a/pkg/rabbitmq/consumer/rabbitmq_consumer_test.go b/pkg/rabbitmq/consumer/rabbitmq_consumer_test.go
@@ -48,7 +48,7 @@ func Test_Consume_Message(t *testing.T) {
 	var consumers []consumer.Consumer
 	consumers = append(consumers, rabbitmqConsumer)
 
-	b := bus.NewRabbitMQBus(defaultLogger.Logger, consumers)
+	b := bus.NewRabbitMQBus(defaultLogger.Logger, consumers...)
 	err = b.Start(context.Background())
 	if err != nil {
 		return
@@ -120,7 +120,7 @@ func Test_Consume_Default_Message(t *testing.T) {
 	var consumers []consumer.Consumer
 	consumers = append(consumers, rabbitmqConsumer)
 
-	b := bus.NewRabbitMQBus(defaultLogger.Logger, consumers)
+	b := bus.NewRabbitMQBus(defaultLogger.Logger, consumers...)
 	err = b.Start(context.Background())
 	if err != nil {
 		return

diff --git a/services/catalogs/read_service/internal/shared/web/workers/rabbitmq_worker.go b/services/catalogs/read_service/internal/shared/web/workers/rabbitmq_worker.go
@@ -8,7 +8,7 @@ import (
 )
 
 func NewRabbitMQWorkerWorker(infra *infrastructure.InfrastructureConfigurations) web.Worker {
-	rabbitMQBus := rabbitmqBus.NewRabbitMQBus(infra.Log, infra.Consumers)
+	rabbitMQBus := rabbitmqBus.NewRabbitMQBus(infra.Log, infra.Consumers...)
 
 	return web.NewBackgroundWorker(func(ctx context.Context) error {
 		err := rabbitMQBus.Start(ctx)

diff --git a/services/orders/internal/shared/web/workers/rabbitmq_worker.go b/services/orders/internal/shared/web/workers/rabbitmq_worker.go
@@ -8,7 +8,7 @@ import (
 )
 
 func NewRabbitMQWorkerWorker(infra *infrastructure.InfrastructureConfiguration) web.Worker {
-	bus := rabbitmqBus.NewRabbitMQBus(infra.Log, infra.Consumers)
+	bus := rabbitmqBus.NewRabbitMQBus(infra.Log, infra.Consumers...)
 	return web.NewBackgroundWorker(func(ctx context.Context) error {
 		err := bus.Start(ctx)
 		if err != nil {