goroutine

taikoxyz · Sep 20, 2023 · 23e35ea · 23e35ea
1 parent 34d8964
commit 23e35ea
Showing 1 changed file with 17 additions and 15 deletions.
diff --git a/packages/relayer/processor/processor.go b/packages/relayer/processor/processor.go
@@ -289,25 +289,27 @@ func (p *Processor) eventLoop(ctx context.Context) {
 		case <-ctx.Done():
 			return
 		case msg := <-p.msgCh:
-			err := p.processMessage(ctx, msg)
-
-			if err != nil {
-				slog.Error("err processing message", "err", err.Error())
-
-				if errors.Is(err, errUnprocessable) {
-					if err := p.queue.Ack(ctx, msg); err != nil {
-						slog.Error("Err acking message", "err", err.Error())
+			go func(msg queue.Message) {
+				err := p.processMessage(ctx, msg)
+
+				if err != nil {
+					slog.Error("err processing message", "err", err.Error())
+
+					if errors.Is(err, errUnprocessable) {
+						if err := p.queue.Ack(ctx, msg); err != nil {
+							slog.Error("Err acking message", "err", err.Error())
+						}
+					} else {
+						if err := p.queue.Nack(ctx, msg); err != nil {
+							slog.Error("Err nacking message", "err", err.Error())
+						}
 					}
 				} else {
-					if err := p.queue.Nack(ctx, msg); err != nil {
-						slog.Error("Err nacking message", "err", err.Error())
+					if err := p.queue.Ack(ctx, msg); err != nil {
+						slog.Error("Err acking message", "err", err.Error())
 					}
 				}
-			} else {
-				if err := p.queue.Ack(ctx, msg); err != nil {
-					slog.Error("Err acking message", "err", err.Error())
-				}
-			}
+			}(msg)
 		}
 	}
 }