+ public void initialize(SocketChannel ch, Promise<? extends NetconfSession> promise){
+ ch.pipeline().addLast("aggregator", new NetconfMessageAggregator(FramingMechanism.EOM));
+ ch.pipeline().addLast(new NetconfXMLToMessageDecoder());
+ initializeAfterDecoder(ch, promise);
+ ch.pipeline().addLast("frameEncoder", FramingMechanismHandlerFactory.createHandler(FramingMechanism.EOM));
+ ch.pipeline().addLast(new NetconfMessageToXMLEncoder());
+ }