This is an automated email from the ASF dual-hosted git repository. boglesby pushed a commit to branch feature/GEODE-7466 in repository https://gitbox.apache.org/repos/asf/geode.git
commit ded358a9242e2436aa73918d9e554a6ea6d65c10 Author: Barry Oglesby <[email protected]> AuthorDate: Fri Nov 15 17:02:46 2019 -0800 GEODE-7466: Closed the existing CacheClientNotifier instance if it exists --- .../java/org/apache/geode/internal/cache/ha/HARegionQueueTest.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/ha/HARegionQueueTest.java b/geode-core/src/test/java/org/apache/geode/internal/cache/ha/HARegionQueueTest.java index cd33f8d..88577d8 100644 --- a/geode-core/src/test/java/org/apache/geode/internal/cache/ha/HARegionQueueTest.java +++ b/geode-core/src/test/java/org/apache/geode/internal/cache/ha/HARegionQueueTest.java @@ -23,6 +23,7 @@ import java.io.IOException; import java.util.HashMap; import java.util.concurrent.ConcurrentHashMap; +import org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier; import org.junit.Before; import org.junit.Test; import org.junit.experimental.categories.Category; @@ -67,6 +68,10 @@ public class HARegionQueueTest { new HAContainerMap(new ConcurrentHashMap()), null, (byte) 1, true, mock(HARegionQueueStats.class), giiLock, rwLock, mock(CancelCriterion.class), false, mock(StatisticsClock.class)); + + if (CacheClientNotifier.getInstance() != null) { + CacheClientNotifier.getInstance().shutdown(0l); + } } @Test
