Repository: geode Updated Branches: refs/heads/feature/GEODE-2632-10 f35a82290 -> 00709dd7a
http://git-wip-us.apache.org/repos/asf/geode/blob/00709dd7/geode-core/src/test/java/org/apache/geode/internal/cache/execute/PRColocationDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/execute/PRColocationDUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/cache/execute/PRColocationDUnitTest.java index 6575b58..c2fcccc 100755 --- a/geode-core/src/test/java/org/apache/geode/internal/cache/execute/PRColocationDUnitTest.java +++ b/geode-core/src/test/java/org/apache/geode/internal/cache/execute/PRColocationDUnitTest.java @@ -1710,7 +1710,8 @@ public class PRColocationDUnitTest extends JUnit4CacheTestCase { } catch (InterruptedException e) { throw new RuntimeException(e); } - assertEquals(0, region1.getDataStore().getAllLocalBucketIds().size()); + assertEquals("Unexpected local bucketIds: " + region1.getDataStore().getAllLocalBucketIds(), + 0, region1.getDataStore().getAllLocalBucketIds().size()); assertEquals(0, region1.getDataStore().getAllLocalPrimaryBucketIds().size()); } }; http://git-wip-us.apache.org/repos/asf/geode/blob/00709dd7/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java index 3556e08..4c37e0d 100644 --- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java @@ -1606,6 +1606,11 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends WANTest } } + /** + * setIgnoreQueue has lots of callers by reflection + * <p> + * TODO: add DistributedRestoreSystemProperties Rule and delete this mess and make constant final + */ public static void setIgnoreQueue(boolean shouldIgnore) { ColocationHelper.IGNORE_UNRECOVERED_QUEUE = shouldIgnore; }
