Unsubscribe is broken on disconnect about philote HOT 6 CLOSED

func (s *Socket) ListenToRedis() {
    rConn := redis.PubSubConn{Conn: RedisPool.Get()}
    //defer rConn.Close()
    defer rConn.Close()

    rConn.Subscribe(s.redisChannels()...)
    s.logMsg("new socket.")
    var (
        message *Message
        err     error
    )

    for {
        switch event := rConn.Receive().(type) {

        case redis.Message:
            //fmt.Printf("%s: %s\n", event.Channel, event.Data)
            err = json.Unmarshal(event.Data, &message)

            //s.logMsg("Event redis: %s", message.Event)
            //s.logMsg("Data redis: %s", message.Data)

            if err != nil {
                s.logMsg("[SECURITY] Redis message isn't JSON: %s", event.Data)
                continue
            }

            switch message.Event {
            case "message":
                //s.logMsg("message.IssuerID %s", message.IssuerID)
                //s.logMsg("s.ID %s", s.ID)
                if message.IssuerID == s.ID {
                    s.logMsg("LOCAL MESSAGE IGNORING")
                    // Message was sent by this connection, ignore.
                    continue
                }

                s.logMsg("Received message from redis on '%s'", message.Channel)
                websocket.JSON.Send(s.ws, &message)

            case "close":

                s.logMsg("Close called, should unsubscribe")
                if message.IssuerID == s.ID {
                    //s.logMsg("unsubscribe %s", s.redisChannels())
                    //rConn.Unsubscribe(message.Channel)
                    //rConn.PUnsubscribe(s.redisChannels()...)
                    err := rConn.Unsubscribe()
                    if err != nil {
                        s.logMsg("error unsubscribe %s: ", err.Error())
                    }

                    s.logMsg("channel len %d", len(s.redisChannels()))

                }

            default:
                s.logMsg("Default msg %s", message.Data)
                break
            }
            break
        case error:
            s.logMsg("Error.")
            defer rConn.Close()
            rConn = redis.PubSubConn{Conn: RedisPool.Get()}
            rConn.Subscribe(s.redisChannels()...)

        case redis.Subscription:
            fmt.Printf("%s: %s %d\n", event.Channel, event.Kind, event.Count)
            if event.Count == 0 {
                log.Println("Done, ending connection.")
                return
            }
            break

        }
    }
}