diff --git a/src/main/java/net/openhft/chronicle/hash/replication/ReplicationHub.java b/src/main/java/net/openhft/chronicle/hash/replication/ReplicationHub.java index b841cf987..890bb0ac7 100644 --- a/src/main/java/net/openhft/chronicle/hash/replication/ReplicationHub.java +++ b/src/main/java/net/openhft/chronicle/hash/replication/ReplicationHub.java @@ -172,7 +172,7 @@ public final class ReplicationHub extends AbstractReplication { @NotNull @Override public ReplicationHub createWithId(byte identifier) { - check(); + check(identifier); return new ReplicationHub(identifier, this); } } diff --git a/src/main/java/net/openhft/chronicle/hash/replication/SingleChronicleHashReplication.java b/src/main/java/net/openhft/chronicle/hash/replication/SingleChronicleHashReplication.java index 03640a894..6032edfc2 100644 --- a/src/main/java/net/openhft/chronicle/hash/replication/SingleChronicleHashReplication.java +++ b/src/main/java/net/openhft/chronicle/hash/replication/SingleChronicleHashReplication.java @@ -36,7 +36,7 @@ public final class SingleChronicleHashReplication extends AbstractReplication { @NotNull @Override public SingleChronicleHashReplication createWithId(byte identifier) { - check(); + check(identifier); return new SingleChronicleHashReplication(identifier, this); } }