public void recordEmitDelay(long emitDelay) {
        this.emitDelay = emitDelay;
    }
@Test
    public void testEmitEventTimeLagTracking() {
        sourceMetrics.recordEmitDelay(3L);
        assertGauge(metricListener, CURRENT_EMIT_EVENT_TIME_LAG, 3L);
    }