ECMap: Moving message serialization to the background

Change-Id: I0de398c6ce77bfb0729db03ab2ec4ea7f55a8284

@@ -429,6 +429,7 @@ public class EventuallyConsistentMapImpl<K, V>
 
 
         executor.shutdown();
         executor.shutdown();
         backgroundExecutor.shutdown();
         backgroundExecutor.shutdown();
+        broadcastMessageExecutor.shutdown();
 
 
         listeners.clear();
         listeners.clear();
 
 
@@ -444,11 +445,11 @@ public class EventuallyConsistentMapImpl<K, V>
     }
     }
 
 
     private void notifyPeers(InternalPutEvent event) {
     private void notifyPeers(InternalPutEvent event) {
-        broadcastMessage(updateMessageSubject, event);
+        broadcastMessageExecutor.execute(() -> broadcastMessage(updateMessageSubject, event));
     }
     }
 
 
     private void notifyPeers(InternalRemoveEvent event) {
     private void notifyPeers(InternalRemoveEvent event) {
-        broadcastMessage(removeMessageSubject, event);
+        broadcastMessageExecutor.execute(() -> broadcastMessage(removeMessageSubject, event));
     }
     }
 
 
     private void broadcastMessage(MessageSubject subject, Object event) {
     private void broadcastMessage(MessageSubject subject, Object event) {
@@ -456,7 +457,7 @@ public class EventuallyConsistentMapImpl<K, V>
                 clusterService.getLocalNode().id(),
                 clusterService.getLocalNode().id(),
                 subject,
                 subject,
                 serializer.encode(event));
                 serializer.encode(event));
-        broadcastMessageExecutor.execute(() -> clusterCommunicator.broadcast(message));
+        clusterCommunicator.broadcast(message);
     }
     }
 
 
     private void unicastMessage(NodeId peer,
     private void unicastMessage(NodeId peer,