diff --git a/pubsub.go b/pubsub.go index b21e5ab..aaea49a 100644 --- a/pubsub.go +++ b/pubsub.go @@ -323,6 +323,8 @@ func (p *PubSub) announce(topic string, sub bool) { select { case peer <- out: default: + // TODO this needs to be reliable, schedule it for piggybacking + // in a subsequent message or retry later log.Infof("dropping announce message to peer %s: queue full", pid) } }