ScheduledExecutorService timer = new ScheduledThreadPoolExecutor(1, new NamedThreadFactory("webpieces-timer"));
HttpFrontendManager frontEndMgr = HttpFrontendFactory.createFrontEnd("frontEnd", 10, timer, pool);
FrontendConfig config = new FrontendConfig("id2", new InetSocketAddress(0));
config.alwaysHttp2 = alwaysHttp2;
config.maxConcurrentStreams = Optional.of(maxConcurrentStreams);
<BUG>HttpServer server = frontEndMgr.createHttpServer(config, new OurListener());
return server.getUnderlyingChannel().getLocalAddress().getPort();</BUG>
}
private static class OurListener implements RequestListener {
private DataWrapperGenerator dataGen = DataWrapperGeneratorFactory.createDataWrapperGenerator();

ScheduledExecutorService timer = new ScheduledThreadPoolExecutor(1, new NamedThreadFactory("webpieces-timer"));
HttpFrontendManager frontEndMgr = HttpFrontendFactory.createFrontEnd("frontEnd", 10, timer, pool);
FrontendConfig config = new FrontendConfig("id2", new InetSocketAddress(0));
config.alwaysHttp2 = alwaysHttp2;
config.maxConcurrentStreams = Optional.of(maxConcurrentStreams);
HttpServer server = frontEndMgr.createHttpServer(config, new OurListener());
server.start();
return server.getUnderlyingChannel().getLocalAddress().getPort();
}
private static class OurListener implements RequestListener {
private DataWrapperGenerator dataGen = DataWrapperGeneratorFactory.createDataWrapperGenerator();
