@Override
    public long currentTime() {
        return timerService.currentProcessingTime();
    }
@Test
    void testCurrentProcessingTime() throws Exception {
        TestInternalTimerService<Integer, VoidNamespace> timerService = getTimerService();
        DefaultProcessingTimeManager manager = new DefaultProcessingTimeManager(timerService);
        long newTime = 100L;
        timerService.advanceProcessingTime(newTime);
        assertThat(manager.currentTime()).isEqualTo(newTime);
    }