Added netty pipeline consumer