diff --git a/broker_redis.go b/broker_redis.go
index 4b51c1bf..1e43ae18 100644
--- a/broker_redis.go
+++ b/broker_redis.go
@@ -702,7 +702,7 @@ func (b *RedisBroker) runPubSub(s *shardWrapper, eventHandler BrokerEventHandler
 	go func() {
 		wg.Wait()
 		if len(channels) > 0 && b.node.LogEnabled(LogLevelDebug) {
-			b.node.Log(NewLogEntry(LogLevelError, "resubscribed to channels", map[string]interface{}{"elapsed": time.Since(started).String(), "numChannels": len(channels)}))
+			b.node.Log(NewLogEntry(LogLevelDebug, "resubscribed to channels", map[string]interface{}{"elapsed": time.Since(started).String(), "numChannels": len(channels)}))
 		}
 		select {
 		case <-done:
diff --git a/client.go b/client.go
index 1412272e..055ef974 100644
--- a/client.go
+++ b/client.go
@@ -1085,7 +1085,7 @@ func (c *Client) HandleCommand(cmd *protocol.Command, cmdProtocolSize int) bool
 	c.mu.Unlock()
 
 	if unusable {
-		go func() { _ = c.close(DisconnectInsufficientState) }()
+		go func() { _ = c.close(DisconnectBadRequest) }()
 		return false
 	}