public void trackDelayedMetricsTenant(String tenantid, final List<Metric> delayedMetrics) {
        if (isTrackingDelayedMetrics) {
            String logMessage = String.format("[TRACKER][DELAYED METRIC] Tenant sending delayed metrics %s", tenantid);
            log.info(logMessage);

            // log individual delayed metrics locator and collectionTime
            double delayedMinutes;
            long nowMillis = System.currentTimeMillis();
            for (Metric metric : delayedMetrics) {
                delayedMinutes = (double)(nowMillis - metric.getCollectionTime()) / 1000 / 60;
                logMessage = String.format("[TRACKER][DELAYED METRIC] %s has collectionTime %s which is delayed by %.2f minutes",
                        metric.getLocator().toString(),
                        dateFormatter.format(new Date(metric.getCollectionTime())),
                        delayedMinutes);
                log.info(logMessage);
            }
        }
    }
public void trackDelayedMetricsTenant(String tenantid, final List<Metric> delayedMetrics) {
        if (isTrackingDelayedMetrics) {
            String logMessage = String.format("[TRACKER][DELAYED METRIC] Tenant sending delayed metrics %s", tenantid);
            log.info(logMessage);

            
            double delayedMinutes;
            long nowMillis = System.currentTimeMillis();
            for (Metric metric : delayedMetrics) {
                delayedMinutes = (double)(nowMillis - metric.getCollectionTime()) / 1000 / 60;
                logMessage = String.format("[TRACKER][DELAYED METRIC] %s has collectionTime %s which is delayed by %.2f minutes",
                        metric.getLocator().toString(),
                        dateFormatter.format(new Date(metric.getCollectionTime())),
                        delayedMinutes);
                log.info(logMessage);
            }
        }
    }
public void trackDelayedMetricsTenant ( String tenantid , final List < Metric > delayedMetrics ) { if ( isTrackingDelayedMetrics ) { String logMessage = String . format ( "[TRACKER][DELAYED METRIC] Tenant sending delayed metrics %s" , tenantid ) ; log . info ( logMessage ) ; // log individual delayed metrics locator and collectionTime double delayedMinutes ; long nowMillis = System . currentTimeMillis ( ) ; for ( Metric metric : delayedMetrics ) { delayedMinutes = ( double ) ( nowMillis - metric . getCollectionTime ( ) ) / 1000 / 60 ; logMessage = String . format ( "[TRACKER][DELAYED METRIC] %s has collectionTime %s which is delayed by %.2f minutes" , metric . getLocator ( ) . toString ( ) , dateFormatter . format ( new Date ( metric . getCollectionTime ( ) ) ) , delayedMinutes ) ; log . info ( logMessage ) ; } } }
This method is used to log delayed metrics, if tracking delayed metrics
is turned on for this Blueflood service.
@param tenantid
@param delayedMetrics
This method is used to log delayed metrics if tracking delayed metrics is turned on for this Blueflood service .