@Test public void testTwoParamSimpleAppend() throws FlumeException, EventDeliveryException { RpcClient client = null; Server server = RpcTestUtils.startServer(new OKAvroHandler()); try { client = RpcClientFactory.getDefaultInstance(localhost, server.getPort()); client.append(EventBuilder.withBody("wheee!!!", Charset.forName("UTF8"))); } finally { RpcTestUtils.stopServer(server); if (client != null) client.close(); } }
public static RpcClient getDefaultInstance(String hostname, Integer port) throws FlumeException { return getDefaultInstance(hostname, port, 0); }
RpcClientFactory { public static RpcClient getDefaultInstance(String hostname, Integer port) throws FlumeException { return getDefaultInstance(hostname, port, 0); } }
RpcClientFactory { public static RpcClient getDefaultInstance(String hostname, Integer port) throws FlumeException { return getDefaultInstance(hostname, port, 0); }  }
RpcClientFactory { public static RpcClient getDefaultInstance(String hostname, Integer port) throws FlumeException { return getDefaultInstance(hostname, port, 0); }  @SuppressWarnings("unchecked") static RpcClient getInstance(Properties properties); static RpcClient getInstance(File propertiesFile); @Deprecated static RpcClient getInstance(String hostname, Integer port); static RpcClient getDefaultInstance(String hostname, Integer port); @Deprecated static RpcClient getInstance(String hostname, Integer port,
      Integer batchSize); static RpcClient getDefaultInstance(String hostname, Integer port,
      Integer batchSize); static RpcClient getThriftInstance(String hostname, Integer port,
    Integer batchSize); static RpcClient getThriftInstance(String hostname, Integer port); static RpcClient getThriftInstance(Properties props); }
RpcClientFactory { public static RpcClient getDefaultInstance(String hostname, Integer port) throws FlumeException { return getDefaultInstance(hostname, port, 0); }  @SuppressWarnings("unchecked") static RpcClient getInstance(Properties properties); static RpcClient getInstance(File propertiesFile); @Deprecated static RpcClient getInstance(String hostname, Integer port); static RpcClient getDefaultInstance(String hostname, Integer port); @Deprecated static RpcClient getInstance(String hostname, Integer port,
      Integer batchSize); static RpcClient getDefaultInstance(String hostname, Integer port,
      Integer batchSize); static RpcClient getThriftInstance(String hostname, Integer port,
    Integer batchSize); static RpcClient getThriftInstance(String hostname, Integer port); static RpcClient getThriftInstance(Properties props);  }