@Test
public void testCurrentProcessingTime() throws Exception {

	@SuppressWarnings("unchecked")
	Triggerable<Integer, String> mockTriggerable = mock(Triggerable.class);
	TestKeyContext keyContext = new TestKeyContext();
	TestProcessingTimeService processingTimeService = new TestProcessingTimeService();
	HeapInternalTimerService<Integer, String> timerService =
			createTimerService(mockTriggerable, keyContext, processingTimeService, testKeyGroupRange, maxParallelism);
	processingTimeService.setCurrentTime(17L);
	assertEquals(17, timerService.currentProcessingTime());
	processingTimeService.setCurrentTime(42);
	assertEquals(42, timerService.currentProcessingTime());
}