origChannelFacotry = new TcpMessagePipelineFactory(LOG, null, receiveExecutor) {
@Override
public ChannelPipeline getPipeline() throws Exception {
final ChannelPipeline pipeline = super.getPipeline();
pipeline.addBefore("messageCodec", "nodeNameWriter", new ChannelNodeNameWriter(cluster));
pipeline.addBefore("nodeNameWriter", "nodeInfoSetter", new SimpleChannelUpstreamHandler() {
@Override
public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
if (nodeName == null)
throw new RuntimeException("nodeName not set!");
final NodeInfo ni = cluster.getNodeInfoByName(nodeName);