@Override
    public long currentProcessingTime() {
        return processingTimeService.getCurrentProcessingTime();
    }
@TestTemplate
    void testCurrentProcessingTime() throws Exception {

        @SuppressWarnings("unchecked")
        Triggerable<Integer, String> mockTriggerable = mock(Triggerable.class);

        TestKeyContext keyContext = new TestKeyContext();
        TestProcessingTimeService processingTimeService = new TestProcessingTimeService();
        InternalTimerServiceImpl<Integer, String> timerService =
                createAndStartInternalTimerService(
                        mockTriggerable,
                        keyContext,
                        processingTimeService,
                        testKeyGroupRange,
                        createQueueFactory());

        processingTimeService.setCurrentTime(17L);
        assertThat(timerService.currentProcessingTime()).isEqualTo(17L);

        processingTimeService.setCurrentTime(42);
        assertThat(timerService.currentProcessingTime()).isEqualTo(42L);
    }