@@ -0,0 +1,1387 @@
+package com.rackspacecloud.blueflood.service;%0A%0Aimport com.netflix.astyanax.connectionpool.exceptions.ConnectionException;%0Aimport com.rackspacecloud.blueflood.io.AstyanaxWriter;%0Aimport org.junit.Test;%0Aimport org.mockito.Matchers;%0A%0Aimport java.util.ArrayList;%0A%0Aimport static org.mockito.Matchers.any;%0Aimport static org.mockito.Matchers.anyLong;%0Aimport static org.mockito.Matchers.argThat;%0Aimport static org.mockito.Mockito.mock;%0Aimport static org.mockito.Mockito.verify;%0Aimport static org.mockito.Mockito.verifyNoMoreInteractions;%0A%0Apublic class RollupBatchWriteRunnableTest %7B%0A%0A    @Test%0A    public void runSendsRollupsToWrierAndDecrementsCount() throws ConnectionException %7B%0A%0A        // given%0A        ArrayList%3CSingleRollupWriteContext%3E wcs = new ArrayList%3CSingleRollupWriteContext%3E();%0A        ArrayList%3CSingleRollupWriteContext%3E wcs2 = new ArrayList%3CSingleRollupWriteContext%3E();%0A        RollupExecutionContext ctx = mock(RollupExecutionContext.class);%0A        AstyanaxWriter writer = mock(AstyanaxWriter.class);%0A        RollupBatchWriteRunnable rbwr = new RollupBatchWriteRunnable(wcs, ctx, writer);%0A%0A        // when%0A        rbwr.run();%0A%0A        // then%0A        verify(writer).insertRollups(Matchers.%3CArrayList%3CSingleRollupWriteContext%3E%3Eany());%0A        verifyNoMoreInteractions(writer);%0A        verify(ctx).decrementWriteCounter(anyLong());%0A        verifyNoMoreInteractions(ctx);%0A    %7D%0A%7D%0A

Add test for RollupBatchWriteRunnable.