public class EagleServiceReporterMetricListener implements EagleMetricListener{

    private EagleServiceClientImpl client;
    private static final Logger LOG = LoggerFactory.getLogger(EagleServiceReporterMetricListener.class);

    public EagleServiceReporterMetricListener(String host, int port, String username, String password) {
        client = new EagleServiceClientImpl(host, port, username, password);
    }

    public EagleServiceReporterMetricListener(String host, int port) {
        client = new EagleServiceClientImpl(host, port, null, null);
    }

    public void onMetricFlushed(List<EagleMetric> metrics) {
        List<GenericMetricEntity> entities = new ArrayList<>();
        for (EagleMetric metric : metrics) {
            String metricName = metric.name;
            entities.add(MetricEntityAdaptor.convert(metricName, metric));
        }
        try {
            int total = entities.size();
            GenericServiceAPIResponseEntity<String> response = client.create(entities, GenericMetricEntity.GENERIC_METRIC_SERVICE);
            if(response.isSuccess()) {
                LOG.info("Wrote " + total + " entities to service");
            }else{
                LOG.error("Failed to write " + total + " entities to service, due to server exception: "+ response.getException());
            }
        }
        catch (Exception ex) {
            LOG.error("Got exception while writing entities: ", ex);
        }
    }
}