Since netty version has been bumped, change are required in the unit test.
Change-Id: I7ff42c9538f4fdfadf1c1677ced81b1afa767e31
Signed-off-by: Alexis de Talhouët <adetalhouet89@gmail.com>
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelPromise;
import io.netty.channel.DefaultChannelPromise;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelPromise;
import io.netty.channel.DefaultChannelPromise;
+import io.netty.channel.EventLoop;
import java.io.IOException;
import java.net.SocketAddress;
import org.apache.sshd.ClientChannel;
import java.io.IOException;
import java.net.SocketAddress;
import org.apache.sshd.ClientChannel;
private SocketAddress remoteAddress;
@Mock
private SocketAddress localAddress;
private SocketAddress remoteAddress;
@Mock
private SocketAddress localAddress;
+ @Mock
+ private EventLoop eventLoop;
private AsyncSshHandler asyncSshHandler;
private AsyncSshHandler asyncSshHandler;
stubAuth();
stubSshClient();
stubChannel();
stubAuth();
stubSshClient();
stubChannel();
stubCtx();
stubRemoteAddress();
stubCtx();
stubRemoteAddress();
doReturn("channel").when(channel).toString();
}
doReturn("channel").when(channel).toString();
}
+ private void stubEventLoop() {
+ doReturn(eventLoop).when(channel).eventLoop();
+ doReturn(Boolean.TRUE).when(eventLoop).inEventLoop();
+ }
+
private void stubSshClient() {
doNothing().when(sshClient).start();
final ConnectFuture connectFuture = mock(ConnectFuture.class);
private void stubSshClient() {
doNothing().when(sshClient).start();
final ConnectFuture connectFuture = mock(ConnectFuture.class);