diff --git a/client/client.go b/client/client.go index 242df4f..8b05a39 100644 --- a/client/client.go +++ b/client/client.go @@ -233,7 +233,7 @@ func handleSubscribeConnLoop(ctx context.Context, msgChan chan *Message, topicUR } select { case <-ctx.Done(): - log.Info("Connection exited", util.ShortTopicURL(topicURL)) + log.Info("%s Connection exited", util.ShortTopicURL(topicURL)) return case <-time.After(10 * time.Second): // TODO Add incremental backoff }