From 818305fe278e0f09a01c60df184f05490a9bd1cd Mon Sep 17 00:00:00 2001 From: Omer Akram Date: Fri, 5 Jul 2024 01:35:13 +0500 Subject: [PATCH] correctly store unregister requests --- session.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/session.go b/session.go index 029f1d9..f460fa7 100644 --- a/session.go +++ b/session.go @@ -70,7 +70,7 @@ func (w *Session) SendMessage(msg messages.Message) ([]byte, error) { return data, nil case messages.MessageTypeUnRegister: unregister := msg.(*messages.UnRegister) - w.unregisterRequests.Store(unregister.RequestID(), unregister.RequestID()) + w.unregisterRequests.Store(unregister.RequestID(), unregister.RegistrationID()) return data, nil case messages.MessageTypePublish: