From e97ab1518bf1058aef4d417533d512955f5301d8 Mon Sep 17 00:00:00 2001 From: adyusupov Date: Thu, 27 Jun 2024 17:08:42 +0300 Subject: [PATCH] feat: log fixed for in memory queue --- queue/queue.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/queue/queue.go b/queue/queue.go index 4389cd8..9a4d71c 100644 --- a/queue/queue.go +++ b/queue/queue.go @@ -94,7 +94,7 @@ func (bus *eventBus) Publish(topic string, data []byte) { if bus.outbox != nil { outboxEvent := convertEventToOutboxEvent(event) if err := bus.outbox.InsertEvent(bus.ctx, outboxEvent); err != nil { - bus.log.Error("Failed to save event to outbox: %v", err) + bus.log.ErrorCtx(bus.ctx, err, "failed to save event to outbox") return } event.ID = outboxEvent.ID