From 0548ee1dfcca5d8761724787e34717d2bb4e9f9a Mon Sep 17 00:00:00 2001 From: yedf2 <120050102@qq.com> Date: Thu, 12 May 2022 17:23:23 +0800 Subject: [PATCH] fix mutisource example --- test/busi/barrier.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/test/busi/barrier.go b/test/busi/barrier.go index 69c7c07..7179e14 100644 --- a/test/busi/barrier.go +++ b/test/busi/barrier.go @@ -106,7 +106,7 @@ func init() { return err } transInSource := pdbGet() - return MustBarrierFromGin(c).CallWithDB(transInSource, func(tx *sql.Tx) error { + return barrier.CallWithDB(transInSource, func(tx *sql.Tx) error { return SagaAdjustBalance(tx, TransInUID, reqFrom(c).Amount, reqFrom(c).TransInResult) }) })) @@ -120,7 +120,7 @@ func init() { return err } transInSource := pdbGet() - return MustBarrierFromGin(c).CallWithDB(transInSource, func(tx *sql.Tx) error { + return barrier.CallWithDB(transInSource, func(tx *sql.Tx) error { return SagaAdjustBalance(tx, TransInUID, -reqFrom(c).Amount, "") }) }))