From d1802ee610ffa0e2fcf34d82370606e4aa0cde15 Mon Sep 17 00:00:00 2001 From: Eric Long Date: Fri, 3 Jan 2020 20:00:10 -0500 Subject: [PATCH] 0004227: cleanup for tests --- .../org/jumpmind/symmetric/route/DataGapRouteReaderTest.java | 3 +-- .../symmetric/service/impl/AbstractRouterServiceTest.java | 5 +---- 2 files changed, 2 insertions(+), 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 index 2d3571cc20..0586564c18 100644 --- 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()); + mock(ISqlTransaction.class), null); context.setDataGaps(dataGaps); return new DataGapRouteReader(context, engine); diff --git a/symmetric-core/src/test/java/org/jumpmind/symmetric/service/impl/AbstractRouterServiceTest.java b/symmetric-core/src/test/java/org/jumpmind/symmetric/service/impl/AbstractRouterServiceTest.java index 03ab8af138..8a0aa747fc 100644 --- a/symmetric-core/src/test/java/org/jumpmind/symmetric/service/impl/AbstractRouterServiceTest.java +++ b/symmetric-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()); + 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();