Extract runMsger()
Use redis's pubsub for backend.
Allow specify redis address via env.