final InetSocketAddress serverAddr = InetSocketAddressUtil.getRandomLoopbackInetSocketAddress();
final BmpSessionListenerFactory bmpSessionListenerFactory = () -> BmpMockTest.this.sessionListener;
final ChannelFuture futureServer = bmpDispatcher.createServer(serverAddr,
- bmpSessionListenerFactory, Optional.<KeyMapping>absent());
+ bmpSessionListenerFactory, Optional.absent());
waitFutureComplete(futureServer);
Channel serverChannel;
int sessionUpWait;
BmpMock.main(new String[]{"--local_address", InetSocketAddressUtil.toHostAndPort(serverAddr).toString(),
"--peers_count", "3", "--pre_policy_routes", "3", "--passive"});
final ChannelFuture futureServer = bmpDispatcher.createClient(serverAddr,
- bmpSessionListenerFactory, Optional.<KeyMapping>absent());
+ bmpSessionListenerFactory, Optional.absent());
waitFutureComplete(futureServer);
Channel serverChannel;
int sessionUpWait;