import org.w3c.dom.Document;
public class NetconfClientSessionNegotiatorTest {
-
private NetconfHelloMessage helloMessage;
private ChannelPipeline pipeline;
private ChannelPromise future;
NetconfClientSessionListener sessionListener = mock(NetconfClientSessionListener.class);
Timer timer = new HashedWheelTimer();
return new NetconfClientSessionNegotiator(helloMessage, startExi, promise, channel, timer, sessionListener,
- timeout);
+ timeout, 16384);
}
private static NetconfHelloMessage createHelloMsg(final String name) throws Exception {
verify(promise).setSuccess(any());
}
-
@Test
public void testNetconfClientSessionNegotiatorWithEXI() throws Exception {
Promise<NetconfClientSession> promise = mock(Promise.class);