diff --git a/src/main/java/net/openhft/chronicle/map/NodeDiscovery.java b/src/main/java/net/openhft/chronicle/map/NodeDiscovery.java
index c094fa6a1..5b58e36ff 100644
--- a/src/main/java/net/openhft/chronicle/map/NodeDiscovery.java
+++ b/src/main/java/net/openhft/chronicle/map/NodeDiscovery.java
@@ -822,21 +822,21 @@ class DiscoveryNodeBytesMarshallable implements BytesMarshallable {
             return;
         }
 
-        LOG.info("Received Proposal");
+
 
         // the host and port the message came from
         this.sourceAddressAndPort.readMarshallable(in);
         if (sourceAddressAndPort.equals(ourAddressAndPort))
             return;
 
+        LOG.info("Received Proposal");
+
         this.remoteNode.readMarshallable(in);
         this.proposedIdentifiersWithHost.readMarshallable(in);
 
         NodeDiscoveryEventListener listener = nodeDiscoveryEventListener.get();
         if (listener != null)
             listener.onRemoteNodeEvent(remoteNode, proposedIdentifiersWithHost);
-
-        onChange();
     }
 
 
diff --git a/src/test/java/net/openhft/chronicle/map/NodeDiscoveryTest.java b/src/test/java/net/openhft/chronicle/map/NodeDiscoveryTest.java
index 9239118be..e7fd74ddb 100644
--- a/src/test/java/net/openhft/chronicle/map/NodeDiscoveryTest.java
+++ b/src/test/java/net/openhft/chronicle/map/NodeDiscoveryTest.java
@@ -14,7 +14,7 @@ public class NodeDiscoveryTest {
 
         final ChronicleMap<Integer, CharSequence> map = nodeDiscovery.discoverMap();
 
-        Thread.sleep(1000000);
+         Thread.sleep(1000000);
     }