[geode] 01/01: GEODE-7466: Closed the existing CacheClientNotifier instance if it exists

[bo...@apache.org]

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 <bo...@pivotal.io>
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