+ if (containsBase11Capability(doc)
+ && containsBase11Capability(sessionPreferences.getHelloMessage().getDocument())) {
+ channel.pipeline().replace("frameEncoder", "frameEncoder",
+ FramingMechanismHandlerFactory.createHandler(FramingMechanism.CHUNK));
+ channel.pipeline().replace("aggregator", "aggregator",
+ new NetconfMessageAggregator(FramingMechanism.CHUNK));
+ channel.pipeline().addAfter("aggregator", "chunkDecoder", new NetconfMessageChunkDecoder());
+ }