X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=third-party%2Fatomix%2Fstorage%2Fsrc%2Fmain%2Fjava%2Fio%2Fatomix%2Futils%2Fserializer%2FNamespace.java;fp=third-party%2Fatomix%2Fstorage%2Fsrc%2Fmain%2Fjava%2Fio%2Fatomix%2Futils%2Fserializer%2FNamespace.java;h=b9eeaf269c9dad75bb06026c8af7a61474daf6c9;hb=6f3a7d9e48861e78be1dfdf00ee41774ffa6bb91;hp=f62ba084ca901fa339e6d35aeb1cb67dc6d2c8bb;hpb=4655e7278357e5b14c86bc24d61671d978475d47;p=controller.git diff --git a/third-party/atomix/storage/src/main/java/io/atomix/utils/serializer/Namespace.java b/third-party/atomix/storage/src/main/java/io/atomix/utils/serializer/Namespace.java index f62ba084ca..b9eeaf269c 100644 --- a/third-party/atomix/storage/src/main/java/io/atomix/utils/serializer/Namespace.java +++ b/third-party/atomix/storage/src/main/java/io/atomix/utils/serializer/Namespace.java @@ -26,7 +26,6 @@ import com.esotericsoftware.kryo.pool.KryoPool; import com.esotericsoftware.kryo.serializers.CompatibleFieldSerializer; import com.google.common.base.MoreObjects; import com.google.common.collect.ImmutableList; -import org.apache.commons.lang3.tuple.Pair; import org.objenesis.strategy.StdInstantiatorStrategy; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -38,6 +37,8 @@ import java.nio.ByteBuffer; import java.util.ArrayList; import java.util.Arrays; import java.util.List; +import java.util.Map; +import java.util.Map.Entry; import java.util.Objects; import static java.util.Objects.requireNonNull; @@ -99,7 +100,7 @@ public final class Namespace implements KryoFactory, KryoPool { //@NotThreadSafe public static final class Builder { private int blockHeadId = INITIAL_ID; - private List[], Serializer>> types = new ArrayList<>(); + private List[], Serializer>> types = new ArrayList<>(); private List blocks = new ArrayList<>(); private ClassLoader classLoader = Thread.currentThread().getContextClassLoader(); private boolean registrationRequired = true; @@ -162,7 +163,7 @@ public final class Namespace implements KryoFactory, KryoPool { * @return this */ public Builder register(Serializer serializer, final Class... classes) { - types.add(Pair.of(classes, requireNonNull(serializer))); + types.add(Map.entry(classes, serializer)); return this; } @@ -431,8 +432,8 @@ public final class Namespace implements KryoFactory, KryoPool { if (id == FLOATING_ID) { id = kryo.getNextRegistrationId(); } - for (Pair[], Serializer> entry : block.types()) { - register(kryo, entry.getLeft(), entry.getRight(), id++); + for (Entry[], Serializer> entry : block.types()) { + register(kryo, entry.getKey(), entry.getValue(), id++); } } return kryo; @@ -520,9 +521,9 @@ public final class Namespace implements KryoFactory, KryoPool { static final class RegistrationBlock { private final int begin; - private final ImmutableList[], Serializer>> types; + private final ImmutableList[], Serializer>> types; - RegistrationBlock(int begin, List[], Serializer>> types) { + RegistrationBlock(int begin, List[], Serializer>> types) { this.begin = begin; this.types = ImmutableList.copyOf(types); } @@ -531,7 +532,7 @@ public final class Namespace implements KryoFactory, KryoPool { return begin; } - public ImmutableList[], Serializer>> types() { + public ImmutableList[], Serializer>> types() { return types; }