From 3e2937764376e7b09dd4735358571e8923af0f33 Mon Sep 17 00:00:00 2001
From: elong <elong@jumpmind.com>
Date: Mon, 23 Nov 2015 13:05:36 -0500
Subject: [PATCH] 0002443: Node communication stops running a push thread for a
 node

---
 .../symmetric/service/impl/NodeCommunicationService.java      | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/NodeCommunicationService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/NodeCommunicationService.java
index d327655286..7aef6bb6ec 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/NodeCommunicationService.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/NodeCommunicationService.java
@@ -22,6 +22,7 @@
 
 import java.util.ArrayList;
 import java.util.Collection;
+import java.util.Collections;
 import java.util.Date;
 import java.util.HashMap;
 import java.util.HashSet;
@@ -29,6 +30,7 @@
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ThreadFactory;
@@ -76,7 +78,7 @@ public NodeCommunicationService(IClusterService clusterService, INodeService nod
         this.currentlyExecuting = new HashMap<NodeCommunication.CommunicationType, Set<String>>();
         CommunicationType[] types = CommunicationType.values();
         for (CommunicationType communicationType : types) {
-            this.currentlyExecuting.put(communicationType, new HashSet<String>());
+            this.currentlyExecuting.put(communicationType, Collections.newSetFromMap(new ConcurrentHashMap<String, Boolean>()));
         }
     }