Merge pull request #386 from klowdo/main

fix(eventstore/mongodb): pass context with transaction to inTx handler
looplab · May 7, 2022 · 9da9436 · 9da9436
2 parents db3d139 + 441b029
commit 9da9436
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)
 				}
 			}