diff --git a/server.go b/server.go index 55bc2b9..2576fe0 100644 --- a/server.go +++ b/server.go @@ -247,6 +247,11 @@ func (this *RedisMultiplexer) initializeClient(localConnection net.Conn, transac myClient.Connection.Close() }() + if this.activeConnectionCount < 1 { + protocol.WriteError([]byte("No Redis server available"), myClient.Writer, true) + return + } + this.HandleClientRequests(myClient) }