@@ -0,0 +1,1590 @@
+package com.rackspacecloud.blueflood.service;%0A%0Aimport org.junit.Test;%0A%0Aimport java.util.concurrent.ThreadPoolExecutor;%0A%0Aimport static org.mockito.Matchers.anyLong;%0Aimport static org.mockito.Mockito.*;%0A%0Apublic class RollupServiceTest %7B%0A%0A    @Test%0A    public void pollSchedulesEligibleSlots() %7B%0A%0A        // given%0A        ScheduleContext context = mock(ScheduleContext.class);%0A        ShardStateManager shardStateManager = mock(ShardStateManager.class);%0A        ThreadPoolExecutor locatorFetchExecutors = mock(ThreadPoolExecutor.class);%0A        ThreadPoolExecutor rollupReadExecutors = mock(ThreadPoolExecutor.class);%0A        ThreadPoolExecutor rollupWriteExecutors = mock(ThreadPoolExecutor.class);%0A        ThreadPoolExecutor enumValidatorExecutor = mock(ThreadPoolExecutor.class);%0A        long rollupDelayMillis = 300000;%0A        long delayedMetricRollupDelayMillis = 300000;%0A%0A        RollupService service = new RollupService(context, shardStateManager,%0A                locatorFetchExecutors, rollupReadExecutors,%0A                rollupWriteExecutors, enumValidatorExecutor, rollupDelayMillis,%0A                delayedMetricRollupDelayMillis);%0A%0A        // when%0A        service.poll();%0A%0A        // then%0A        verify(context).scheduleEligibleSlots(anyLong(), anyLong());%0A        verifyNoMoreInteractions(context);%0A%0A        verifyZeroInteractions(shardStateManager);%0A        verifyZeroInteractions(locatorFetchExecutors);%0A        verifyZeroInteractions(rollupReadExecutors);%0A        verifyZeroInteractions(rollupWriteExecutors);%0A        verifyZeroInteractions(enumValidatorExecutor);%0A    %7D%0A%7D%0A

Test the poll method.