@Override
protected ChannelPipelineFactory createPipelineFactory(final ChannelGroup group) {
return new ChannelPipelineFactory() {
private final ChannelGroupHandler groupHandler = new ChannelGroupHandler(group);
private final HashedWheelTimer timer = new HashedWheelTimer();
private final TimeUnit TIMEOUT_UNIT = TimeUnit.SECONDS;
public ChannelPipeline getPipeline() throws Exception {