diff --git a/pubsub.go b/pubsub.go index d607cc5..a4f68a7 100644 --- a/pubsub.go +++ b/pubsub.go @@ -326,7 +326,11 @@ func (p *PubSub) notifySubs(msg *pb.Message) { for _, topic := range msg.GetTopicIDs() { subs := p.myTopics[topic] for f := range subs { - f.ch <- &Message{msg} + select { + case f.ch <- &Message{msg}: + default: + log.Infof("Can't deliver message to subscription for topic %s; subscriber too slow", topic) + } } } }