X-Git-Url: https://git.argeo.org/?a=blobdiff_plain;ds=sidebyside;f=org.argeo.api.uuid%2Fsrc%2Forg%2Fargeo%2Fapi%2Fuuid%2FConcurrentUuidFactory.java;h=264e047063ac0872af99f1fc8b0adeba0530aaa3;hb=0f8bddc982e2ea4f260e1eb639777b74e7893ea3;hp=15245b2932f50074f374b8156b06d696ee77cf8a;hpb=593a4eabb76b74cd382ecf3f181d57abe0d643f9;p=lgpl%2Fargeo-commons.git diff --git a/org.argeo.api.uuid/src/org/argeo/api/uuid/ConcurrentUuidFactory.java b/org.argeo.api.uuid/src/org/argeo/api/uuid/ConcurrentUuidFactory.java index 15245b293..264e04706 100644 --- a/org.argeo.api.uuid/src/org/argeo/api/uuid/ConcurrentUuidFactory.java +++ b/org.argeo.api.uuid/src/org/argeo/api/uuid/ConcurrentUuidFactory.java @@ -19,17 +19,17 @@ import java.util.UUID; public class ConcurrentUuidFactory extends AbstractAsyncUuidFactory implements TypedUuidFactory { private final static Logger logger = System.getLogger(ConcurrentUuidFactory.class.getName()); - public ConcurrentUuidFactory(byte[] nodeId) { - this(nodeId, 0); + public ConcurrentUuidFactory(long initialClockRange, byte[] nodeId) { + this(initialClockRange, nodeId, 0); } - public ConcurrentUuidFactory(byte[] nodeId, int offset) { + public ConcurrentUuidFactory(long initialClockRange, byte[] nodeId, int offset) { Objects.requireNonNull(nodeId); if (offset + 6 > nodeId.length) throw new IllegalArgumentException("Offset too big: " + offset); byte[] defaultNodeId = toNodeIdBytes(nodeId, offset); long nodeIdBase = NodeIdSupplier.toNodeIdBase(defaultNodeId); - setNodeIdSupplier(() -> nodeIdBase); + setNodeIdSupplier(() -> nodeIdBase, initialClockRange); } /**