in flume-legacy-avro-source/src/main/java/org/apache/flume/source/avroLegacy/AvroLegacySource.java [104:115]
public void start() {
// setup http server to receive OG events
res = new SpecificResponder(FlumeOGEventAvroServer.class, this);
try {
http = new HttpServer(res, host, port);
} catch (IOException eI) {
LOG.warn("Failed to start server", eI);
return;
}
http.start();
super.start();
}