Skip to content

Commit

Permalink
feat: log fixed for in memory queue
Browse files Browse the repository at this point in the history
  • Loading branch information
adyusupov committed Jun 27, 2024
1 parent 058d3b6 commit e97ab15
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion queue/queue.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit e97ab15

Please sign in to comment.