fix branch register response (#401)

* fix branch register response
apache · Dec 13, 2022 · 27bd6ac · 27bd6ac
1 parent dcb6ec9
commit 27bd6ac
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/pkg/rm/rm_remoting.go b/pkg/rm/rm_remoting.go
@@ -18,6 +18,7 @@
 package rm
 
 import (
+	"fmt"
 	"sync"
 
 	"github.com/pkg/errors"
@@ -59,7 +60,11 @@ func (r *RMRemoting) BranchRegister(param BranchRegisterParam) (int64, error) {
 		log.Errorf("BranchRegister error: %v, res %v", err.Error(), resp)
 		return 0, err
 	}
-	return resp.(message.BranchRegisterResponse).BranchId, nil
+	branchResp := resp.(message.BranchRegisterResponse)
+	if branchResp.ResultCode == message.ResultCodeFailed {
+		return 0, fmt.Errorf("Response %s", branchResp.Msg)
+	}
+	return branchResp.BranchId, nil
 }
 
 // BranchReport Report status of transaction branch