diff --git a/src/test/java/net/openhft/chronicle/map/TestReplication.java b/src/test/java/net/openhft/chronicle/map/TestReplication.java
new file mode 100644
index 000000000..e967af61c
--- /dev/null
+++ b/src/test/java/net/openhft/chronicle/map/TestReplication.java
@@ -0,0 +1,57 @@
+package net.openhft.chronicle.map;
+
+import net.openhft.chronicle.hash.replication.TcpTransportAndNetworkConfig;
+import net.openhft.chronicle.map.ChronicleMap;
+import net.openhft.chronicle.map.ChronicleMapBuilder;
+import org.junit.Assert;
+import org.junit.Test;
+
+import java.net.InetSocketAddress;
+
+/**
+ * Created by Rob Austin
+ */
+public class TestReplication {
+
+
+    @Test
+    public void testAllDataGetsReplicated() throws InterruptedException {
+
+
+        TcpTransportAndNetworkConfig tcpConfigServer1 =
+                TcpTransportAndNetworkConfig.of(8082);
+
+        TcpTransportAndNetworkConfig tcpConfigServer2 =
+                TcpTransportAndNetworkConfig.of(8083, new InetSocketAddress("localhost",
+                        8082));
+
+        final ChronicleMap<Integer, Integer> map2 = ChronicleMapBuilder.of(Integer.class,
+                Integer.class)
+                .replication((byte) 2, tcpConfigServer2)
+                .create();
+
+
+        final ChronicleMap<Integer, Integer> map1 = ChronicleMapBuilder.of(Integer.class,
+                Integer.class)
+                .replication((byte) 3, tcpConfigServer1)
+                .create();
+
+        for (int i = 0; i < 70000; i++) {
+            map1.put(i, i);
+        }
+
+        for (int i = 0; i < 10; i++) {
+
+            Thread.sleep(100);
+            System.out.println(map2.size());
+        }
+
+
+        Assert.assertEquals(map1.size(),map2.size());
+
+    }
+
+
+    
+
+}