@Override
public void open() throws IOException {
URL url = new URL("http", host, port, "/");
Transceiver http = new HttpTransceiver(url);
transport = new AccountingTransceiver(http);
try {
this.avroClient = (FlumeEventAvroServer) SpecificRequestor.getClient(
FlumeEventAvroServer.class, transport);
} catch (Exception e) {
throw new IOException("Failed to open Avro event sink at " + host + ":"