From 744472d7b733fdd1ded78f683b39db8cb8f54f67 Mon Sep 17 00:00:00 2001 From: Hooman Familrouhani Date: Mon, 30 May 2022 17:37:49 -0700 Subject: [PATCH] fixed bug if retry count is 1 --- pkg/consumer_factory.go | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) diff --git a/pkg/consumer_factory.go b/pkg/consumer_factory.go index ecea543..1d4e9c3 100644 --- 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)) } }