@Test(expected = FlumeException.class)
public void testUnableToConnect() throws FlumeException {

  @SuppressWarnings("unused")
  NettyAvroRpcClient client = new NettyAvroRpcClient();
  Properties props = new Properties();
  props.setProperty(RpcClientConfigurationConstants.CONFIG_HOSTS, "localhost");
  props.setProperty(RpcClientConfigurationConstants.CONFIG_HOSTS_PREFIX + "localhost",
      localhost + ":" + 1);
  client.configure(props);
}