File | Line |
---|
org/apache/logging/log4j/flume/appender/FlumeAvroManager.java | 142 |
org/apache/logging/log4j/flume/appender/FlumeAvroManager.java | 167 |
rpcClient.appendBatch(events.getEvents());
} catch (final Exception ex) {
rpcClient.close();
rpcClient = null;
final String msg = "Unable to write to " + getName() + " at " + agents[current].getHost() + ":" +
agents[current].getPort();
LOGGER.warn(msg, ex);
throw new AppenderRuntimeException("No Flume agents are available");
}
} else {
final String msg = "Unable to write to " + getName() + " at " + agents[current].getHost() + ":" +
agents[current].getPort();
LOGGER.warn(msg);
throw new AppenderRuntimeException("No Flume agents are available");
}
} |