diff --git a/internal/rpc/core/mempool.go b/internal/rpc/core/mempool.go index 1c5946ed8..899d51635 100644 --- a/internal/rpc/core/mempool.go +++ b/internal/rpc/core/mempool.go @@ -72,6 +72,12 @@ func (env *Environment) BroadcastTxCommit(ctx *rpctypes.Context, tx types.Tx) (* } r := (<-resCh).GetCheckTx() + if r.Code != abci.CodeTypeOK { + return &coretypes.ResultBroadcastTxCommit{ + CheckTx: *r, + Hash: tx.Hash(), + }, fmt.Errorf("transaction encountered error (%s)", r.MempoolError) + } if !indexer.KVSinkEnabled(env.EventSinks) { return &coretypes.ResultBroadcastTxCommit{