diff --git a/protocol/dubbo/client.go b/protocol/dubbo/client.go index ebbc28e1cb99730c9d37bc2356c003bcb0b799f0..c60b265cbcc0fd9ff2b98b036bf9a55a5e4a6241 100644 --- a/protocol/dubbo/client.go +++ b/protocol/dubbo/client.go @@ -207,7 +207,7 @@ func (c *Client) call(ct CallType, addr string, svcUrl common.URL, method string } select { - case <-time.After(c.opts.RequestTimeout): + case <-getty.GetTimeWheel().After(c.opts.RequestTimeout): err = errClientReadTimeout c.removePendingResponse(SequenceType(rsp.seq)) case <-rsp.done: