diff --git a/registry/consul/registry.go b/registry/consul/registry.go index 35c2e6d992f278882b2b3ddcd87beb19821e9965..116ab4d7f31ff0668b6286871d75ea853bfc8cf5 100644 --- a/registry/consul/registry.go +++ b/registry/consul/registry.go @@ -18,6 +18,7 @@ package consul import ( + getty "github.com/apache/dubbo-getty" "strconv" "time" ) @@ -210,7 +211,7 @@ func (r *consulRegistry) Destroy() { select { case <-done: logger.Infof("consulRegistry unregister done") - case <-time.After(registryDestroyDefaultTimeout): + case <-getty.GetTimeWheel().After(registryDestroyDefaultTimeout): logger.Errorf("consul unregister timeout") }