diff --git a/server/server.go b/server/server.go index 1677133..8a4655b 100644 --- a/server/server.go +++ b/server/server.go @@ -1420,8 +1420,12 @@ func (s *Server) execManager() { defer s.mu.Unlock() for _, t := range s.topics { subs := t.SubscribersCount() - expiryTime := time.Until(t.lastVisitorExpires) - log.Tag(tagManager).Trace("- topic %s: %d subscribers, expires in %s", t.ID, subs, expiryTime) + expiryMessage := "" + if subs == 0 { + expiryTime := time.Until(t.lastVisitorExpires) + expiryMessage = ", expires in " + expiryTime.String() + } + log.Tag(tagManager).Trace("- topic %s: %d subscribers%s", t.ID, subs, expiryMessage) msgs, exists := messageCounts[t.ID] if t.Stale() && (!exists || msgs == 0) { log.Tag(tagManager).Trace("Deleting empty topic %s", t.ID)