diff --git a/server/events.go b/server/events.go index 22712480..3b157cef 100644 --- a/server/events.go +++ b/server/events.go @@ -2159,9 +2159,9 @@ func (s *Server) accountConnectEvent(c *client) { MQTTClient: c.getMQTTClientID(), }, } + subj := fmt.Sprintf(connectEventSubj, c.acc.Name) c.mu.Unlock() - subj := fmt.Sprintf(connectEventSubj, c.acc.Name) s.sendInternalMsgLocked(subj, _EMPTY_, &m.Server, &m) }