Move Redis subscription listening code to RedisSubscriber.