diff --git a/internal/server/pubsub.go b/internal/server/pubsub.go index ce185689..22c973e8 100644 --- a/internal/server/pubsub.go +++ b/internal/server/pubsub.go @@ -215,7 +215,9 @@ func (s *Server) liveSubscription( } case RESP: if len(msg.Args) > 1 { - data := redcon.AppendBulkString(nil, msg.Args[1]) + data := redcon.AppendArray(nil, 2) + data = redcon.AppendBulkString(data, "PONG") + data = redcon.AppendBulkString(data, msg.Args[1]) write(data) } else { write([]byte("+PONG\r\n"))