public class HttpServer {
    private Server server;
    private ServletContextHandler context;

    public HttpServer(int port) {
        server = new Server(port);
        context = new ServletContextHandler();
        context.setContextPath("/");
        server.setHandler(context);
        context.addServlet(new ServletHolder(new MetricsServlet()), "/metrics");
        context.addServlet(new ServletHolder(new HttpServlet() {
            @Override
            protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws IOException {
                resp.setContentType("text/html;charset=UTF-8");
                PrintWriter out = resp.getWriter();
                resp.setStatus(HttpServletResponse.SC_OK);
                try {
                    out.println("Health is A Okay");
                } finally {
                    out.close();
                }
            }
        }), "/healthz");
        context.addServlet("...", "/async/topic/*");
        context.addServlet("...", "/sync/topic/*");;
    }

    public void start() throws Exception {
        this.server.start();
        this.server.join();
    }

    public void stop(String timestamp) throws Exception {
        Logger.info(timestamp + " : Stopping Http Server...");
        this.server.stop();
    }
}