fixed bug if retry count is 1

thumperware · May 31, 2022 · 744472d · 744472d
1 parent b0868ab
commit 744472d
Showing 1 changed file with 6 additions and 8 deletions.
diff --git a/pkg/consumer_factory.go b/pkg/consumer_factory.go
@@ -46,13 +46,11 @@ func CreateConsumer[T handler.IMessage](bus IBus, handler handler.IHandler[T]) {
 			panic(formatter.FormatErr(methodPath, err))
 		}
 		nextRetryQueue = retryQueue
-		if i == 1 {
-			firstQueue := queue.NewQueue(bus.Connection(), msgPath, handlerPath)
-			firstConsumer := consumer.NewConsumer(bus.Connection(), handler, firstQueue, retryQueue, errQueue, 0)
-			err = firstConsumer.Consume()
-			if err != nil {
-				panic(formatter.FormatErr(methodPath, err))
-			}
-		}
+	}
+	firstQueue := queue.NewQueue(bus.Connection(), msgPath, handlerPath)
+	firstConsumer := consumer.NewConsumer(bus.Connection(), handler, firstQueue, nextRetryQueue, errQueue, 0)
+	err = firstConsumer.Consume()
+	if err != nil {
+		panic(formatter.FormatErr(methodPath, err))
 	}
 }