diff --git a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java index 01bfb80aa..9a3eebdfe 100644 --- a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java +++ b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java @@ -300,6 +300,10 @@ final class TcpReplicator extends AbstractChannelReplicator implements Clo } final Attached attachment = (Attached) key.attachment(); + + if (attachment == null) + continue; + if (!attachment.hasRemoteHeartbeatInterval) continue;