redis receiver
Move pipeline redis reader and sender
refactoring
refactoring
introduce redis channel
use redis channel
refactor