pipeline = mockChannelPipeline();
future = mockChannelFuture();
channel = mockChannel();
- System.out.println("setup done");
}
- private ChannelHandler mockChannelHandler() {
+ private static ChannelHandler mockChannelHandler() {
ChannelHandler handler = mock(ChannelHandler.class);
return handler;
}
return channel;
}
- private ChannelFuture mockChannelFuture() {
+ private static ChannelFuture mockChannelFuture() {
ChannelFuture future = mock(ChannelFuture.class);
doReturn(future).when(future).addListener(any(GenericFutureListener.class));
return future;
}
- private ChannelPipeline mockChannelPipeline() {
+ private static ChannelPipeline mockChannelPipeline() {
ChannelPipeline pipeline = mock(ChannelPipeline.class);
ChannelHandler handler = mock(ChannelHandler.class);
doReturn(pipeline).when(pipeline).addAfter(anyString(), anyString(), any(ChannelHandler.class));
return pipeline;
}
- private NetconfClientSessionNegotiator createNetconfClientSessionNegotiator(final Promise promise,
+ private NetconfClientSessionNegotiator createNetconfClientSessionNegotiator(final Promise<NetconfClientSession> promise,
final NetconfMessage startExi) {
ChannelProgressivePromise progressivePromise = mock(ChannelProgressivePromise.class);
NetconfClientSessionPreferences preferences = new NetconfClientSessionPreferences(helloMessage, startExi);
NetconfClientSessionNegotiator negotiator = createNetconfClientSessionNegotiator(promise, null);
negotiator.channelActive(null);
- Set caps = Sets.newSet("a", "b");
+ Set<String> caps = Sets.newSet("a", "b");
NetconfHelloMessage helloServerMessage = NetconfHelloMessage.createServerHello(caps, 10);
negotiator.handleMessage(helloServerMessage);
verify(promise).setSuccess(anyObject());
NetconfClientSessionNegotiator negotiator = createNetconfClientSessionNegotiator(promise, exiMessage);
negotiator.channelActive(null);
- Set caps = Sets.newSet("exi:1.0");
+ Set<String> caps = Sets.newSet("exi:1.0");
NetconfHelloMessage helloMessage = NetconfHelloMessage.createServerHello(caps, 10);
doAnswer(new Answer<Object>() {