diff --git a/Discover.go b/Discover.go index 9a7c5a8..561a9b7 100644 --- a/Discover.go +++ b/Discover.go @@ -195,7 +195,7 @@ func (d *Discoverer) startSub() bool { } if d.pubsubRedisPool == nil { - d.pubsubRedisPool = redis.GetRedis(d.registry, d.logger.New(id.MakeID(12))) + d.pubsubRedisPool = redis.GetRedis(d.registry, d.logger.New(id.Get12BytesUltraPerSecond())) // 订阅所有已注册的应用 for app := range d.appSubscribed { d.subscribeApp(app)