-
- @Override
- protected void initializeSessionNegotiator(final Channel ch, final Promise<NetconfClientSession> promise) {
- ch.pipeline().addAfter(NETCONF_MESSAGE_DECODER, AbstractChannelInitializer.NETCONF_SESSION_NEGOTIATOR,
- negotiatorFactory.getSessionNegotiator(() -> sessionListener, ch, promise));
- }