-
- @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));
- ch.config().setConnectTimeoutMillis((int)negotiatorFactory.getConnectionTimeoutMillis());
- }