Commit de9794a3 authored by jiangpeng's avatar jiangpeng

mempool:fix msg duplicate reply

parent ac94fe0f
......@@ -51,6 +51,7 @@ func (mem *Mempool) SetQueueClient(client queue.Client) {
reply, err = mem.mainGrpcCli.GetProperFee(context.Background(), &types.ReqProperFee{})
default:
msg.Reply(client.NewMessage(mem.key, types.EventReply, types.ErrActionNotSupport))
continue
}
if err != nil {
msg.Reply(client.NewMessage(mem.key, types.EventReply, err))
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment