diff --git a/distributor/xmpp.go b/distributor/xmpp.go index f07e9a2..5c8547c 100644 --- a/distributor/xmpp.go +++ b/distributor/xmpp.go @@ -128,6 +128,10 @@ func (s *XMPPService) Register(appName, token string) (string, string, error) { logger.Errorf("xmpp recv IQ for register: %v", err) return "", "xmpp unable recv iq to gateway", err } + if err := t.Close(); err != nil { + logger.Errorf("unable to close registration response %v", err) + return "", "xmpp unable recv iq to gateway", err + } if endpoint := iqRegister.Register.Endpoint; endpoint != nil { logger.WithField("endpoint", endpoint.Body).Info("success") return endpoint.Body, "", nil