From 441b029a01cd8621fa47091adf780749e4f99432 Mon Sep 17 00:00:00 2001 From: Felix Svensson Date: Fri, 11 Mar 2022 15:14:01 +0100 Subject: [PATCH] fix(eventstore/mongodb): pass context with transaction to inTx handler --- eventstore/mongodb_v2/eventstore.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/eventstore/mongodb_v2/eventstore.go b/eventstore/mongodb_v2/eventstore.go index fc732fcf..e37c9d2f 100644 --- a/eventstore/mongodb_v2/eventstore.go +++ b/eventstore/mongodb_v2/eventstore.go @@ -354,7 +354,7 @@ func (s *EventStore) Save(ctx context.Context, events []eh.Event, originalVersio if s.eventHandlerInTX != nil { for _, e := range events { - if err := s.eventHandlerInTX.HandleEvent(ctx, e); err != nil { + if err := s.eventHandlerInTX.HandleEvent(txCtx, e); err != nil { return nil, fmt.Errorf("could not handle event in transaction: %w", err) } }