0004227: cleanup for tests

JumpMind · Jan 4, 2020 · d1802ee · d1802ee
1 parent 2a7af10
commit d1802ee
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 6 deletions.
diff --git a/symmetric-core/src/test/java/org/jumpmind/symmetric/route/DataGapRouteReaderTest.java b/symmetric-core/src/test/java/org/jumpmind/symmetric/route/DataGapRouteReaderTest.java
@@ -26,7 +26,6 @@
 import static org.mockito.Mockito.when;
 
 import java.util.ArrayList;
-import java.util.HashMap;
 import java.util.Iterator;
 import java.util.List;
 import java.util.concurrent.BlockingQueue;
@@ -136,7 +135,7 @@ protected DataGapRouteReader buildReader(int peekAheadMemoryThreshold, List<Data
         when(engine.getRouterService()).thenReturn(routerService);
 
         ChannelRouterContext context = new ChannelRouterContext(NODE_ID, nodeChannel,
-                mock(ISqlTransaction.class), new HashMap<String, IBatchAlgorithm>());
+                mock(ISqlTransaction.class), null);
         context.setDataGaps(dataGaps);
 
         return new DataGapRouteReader(context, engine);

diff --git a/...ric-core/src/test/java/org/jumpmind/symmetric/service/impl/AbstractRouterServiceTest.java b/...ric-core/src/test/java/org/jumpmind/symmetric/service/impl/AbstractRouterServiceTest.java
@@ -23,7 +23,6 @@
 import java.sql.Types;
 import java.util.ArrayList;
 import java.util.Calendar;
-import java.util.HashMap;
 import java.util.Iterator;
 import java.util.List;
 import java.util.Set;
@@ -45,7 +44,6 @@
 import org.jumpmind.symmetric.model.TriggerRouter;
 import org.jumpmind.symmetric.route.ChannelRouterContext;
 import org.jumpmind.symmetric.route.DataGapRouteReader;
-import org.jumpmind.symmetric.route.IBatchAlgorithm;
 import org.junit.Assert;
 import org.junit.Test;
 
@@ -943,8 +941,7 @@ public void testDontSelectOldDataDuringRouting() throws Exception {
         deleteAll(TEST_TABLE_1);
 
         ISqlTransaction transaction = getSqlTemplate().startSqlTransaction();
-        ChannelRouterContext context = new ChannelRouterContext(TestConstants.TEST_ROOT_EXTERNAL_ID, testChannel, transaction, 
-                new HashMap<String, IBatchAlgorithm>());
+        ChannelRouterContext context = new ChannelRouterContext(TestConstants.TEST_ROOT_EXTERNAL_ID, testChannel, transaction, null);
         context.setDataGaps(engine.getDataService().findDataGaps());
         DataGapRouteReader reader = new DataGapRouteReader(context, engine);
         reader.run();