Refactor RedisMqServer to use the extracted RedisPubServer