From 5cec5375c453c0a4936499f33f918d1789e61e95 Mon Sep 17 00:00:00 2001 From: Matt Lane Date: Fri, 19 Jan 2018 12:08:20 -0600 Subject: [PATCH] added new exported unregister session call --- registry.go | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/registry.go b/registry.go index ac074d2da..3c1fb2af8 100644 --- a/registry.go +++ b/registry.go @@ -50,6 +50,19 @@ func SendToTarget(m Messagable, sessionID SessionID) error { return session.queueForSend(msg) } +//UnregisterSession removes a session from the set of known sessions +func UnregisterSession(sessionID SessionID) error { + sessionsLock.Lock() + defer sessionsLock.Unlock() + + if _, ok := sessions[sessionID]; ok { + delete(sessions, sessionID) + return nil + } + + return errUnknownSession +} + func registerSession(s *session) error { sessionsLock.Lock() defer sessionsLock.Unlock()