From da06ba106e1826dbeae1b3220ff093ed77da9ff7 Mon Sep 17 00:00:00 2001
From: leventov <leventov@ya.ru>
Date: Sat, 25 Jul 2015 19:19:38 +0300
Subject: [PATCH] added a Null check for - modificationNotifier != null

---
 .../chronicle/map/ReplicatedChronicleMap.java     |  3 ++-
 ...plicateProxyMapUpdatedViaSharedMemoryTest.java | 15 +++++----------
 2 files changed, 7 insertions(+), 11 deletions(-)

diff --git a/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java b/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java
index 995281ad2..b5589e21d 100644
--- a/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java
+++ b/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java
@@ -528,7 +528,8 @@ public class ReplicatedChronicleMap<K, KI, MKI extends MetaBytesInterop<K, ? sup
             LOG.debug("raise change: id {}, segment {}, pos {}",
                     localIdentifier, segmentIndex, pos);
             changesForUpdates.set(combine(segmentIndex, pos));
-            modificationNotifier.onChange();
+            if (modificationNotifier != null)
+                modificationNotifier.onChange();
         }
 
         boolean dropChange(long segmentIndex, long pos) {
diff --git a/src/test/java/net/openhft/chronicle/map/ReplicateProxyMapUpdatedViaSharedMemoryTest.java b/src/test/java/net/openhft/chronicle/map/ReplicateProxyMapUpdatedViaSharedMemoryTest.java
index 2ebb3331e..078957a44 100644
--- a/src/test/java/net/openhft/chronicle/map/ReplicateProxyMapUpdatedViaSharedMemoryTest.java
+++ b/src/test/java/net/openhft/chronicle/map/ReplicateProxyMapUpdatedViaSharedMemoryTest.java
@@ -1,26 +1,20 @@
 package net.openhft.chronicle.map;
 
-import org.junit.Assert;
 import net.openhft.chronicle.hash.replication.TcpTransportAndNetworkConfig;
+import org.junit.Assert;
 import org.junit.Test;
 
 import java.io.File;
 import java.io.IOException;
 import java.net.InetSocketAddress;
+import java.util.concurrent.TimeUnit;
 
 /**
  * Created by khoxsey on 5/22/15.
  */
 public class ReplicateProxyMapUpdatedViaSharedMemoryTest {
 
-    /**
-     * test 2 maps on one server ( one that replicates vai TCP/IP and one that just shares memory )
-     * can connect to a remote map
-     * connect to a remote map
-     * @throws IOException
-     * @throws InterruptedException
-     */
-    @Test
+    @Test(timeout = 10000)
     public void testReplicateProxyMapUpdatedViaSharedMemory() throws IOException, InterruptedException {
 
         ChronicleMap<String, String> server1 = null;
@@ -33,7 +27,8 @@ public class ReplicateProxyMapUpdatedViaSharedMemoryTest {
             server1 = ChronicleMapBuilder.of(String.class, String.class)
                     .replication((byte) 1).createPersistedTo(tempFile);
 
-            TcpTransportAndNetworkConfig serverConfig = TcpTransportAndNetworkConfig.of(7077);
+            TcpTransportAndNetworkConfig serverConfig = TcpTransportAndNetworkConfig.of(7077)
+                    .heartBeatInterval(500, TimeUnit.MILLISECONDS);
             replicationMap = ChronicleMapBuilder.of(String.class, String.class)
                     .replication((byte) 1, serverConfig).createPersistedTo(tempFile);
         }