final String name = cluster.getMyNodeInfo().getName();
LOG.debug("Writing node name, {}, to channel.", name);
final byte[] array = name.getBytes(Charsets.UTF_8);
final ChannelBuffer message = ChannelBuffers.wrappedBuffer(array);
ctx.sendDownstream(new DownstreamMessageEvent(channel, new DefaultChannelFuture(channel, false), message, null));
super.channelConnected(ctx, e);
ctx.getPipeline().remove(this);
}