throw new UnableToConnectException(ioe).setConnectUrl(connectUrl);
} else {
failedCollectorConnectionsCounter.compareAndSet(NUMBER_OF_SKIPPED_COLLECTOR_EXCEPTIONS, 0);
if (LOG.isDebugEnabled()) {
LOG.debug(String.format("Ignoring %s AMS connection exceptions", NUMBER_OF_SKIPPED_COLLECTOR_EXCEPTIONS));
<BUG>}
}</BUG>
}
}
<BUG>protected void emitMetrics(TimelineMetrics metrics) {
</BUG>
String connectUrl = getCollectorUri();

throw new UnableToConnectException(ioe).setConnectUrl(connectUrl);
} else {
failedCollectorConnectionsCounter.compareAndSet(NUMBER_OF_SKIPPED_COLLECTOR_EXCEPTIONS, 0);
if (LOG.isDebugEnabled()) {
LOG.debug(String.format("Ignoring %s AMS connection exceptions", NUMBER_OF_SKIPPED_COLLECTOR_EXCEPTIONS));
}
return false;
}
}
}
protected boolean emitMetrics(TimelineMetrics metrics) {
String connectUrl = getCollectorUri();
