diff --git a/mq/publishers.go b/mq/publishers.go index d4f1e5317..236c5ae12 100644 --- a/mq/publishers.go +++ b/mq/publishers.go @@ -55,7 +55,7 @@ func PublishPeerUpdate(replacePeers bool) error { for _, host := range hosts { host := host - time.Sleep(1 * time.Millisecond) + time.Sleep(10 * time.Millisecond) go func(host models.Host) { if err = PublishSingleHostPeerUpdate(&host, allNodes, nil, nil, replacePeers, nil); err != nil { id := host.Name