This is an automated email from the ASF dual-hosted git repository. jbarrett pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/geode.git
commit f410b7e571ba6fff507078a7d2fe5e63bbda3aa3 Author: Jacob Barrett <jbarr...@pivotal.io> AuthorDate: Thu May 20 18:50:07 2021 -0700 GEODE-6588: Cleanup FilterRoutingInfo --- .../java/org/apache/geode/internal/cache/FilterRoutingInfo.java | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/FilterRoutingInfo.java b/geode-core/src/main/java/org/apache/geode/internal/cache/FilterRoutingInfo.java index ca7c4b0..f73918d 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/FilterRoutingInfo.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/FilterRoutingInfo.java @@ -43,9 +43,6 @@ import org.apache.geode.internal.serialization.StaticSerialization; */ public class FilterRoutingInfo implements VersionedDataSerializable { - private static final boolean OLD_MEMBERS_OPTIMIZED = - Boolean.getBoolean("optimized-cq-serialization"); - @Immutable private static final KnownVersion[] serializationVersions = new KnownVersion[0]; @@ -263,9 +260,6 @@ public class FilterRoutingInfo implements VersionedDataSerializable { */ private transient byte[] myData; - /** version of creator of myData, needed for deserialization */ - private transient KnownVersion myDataVersion; - /** Clients that are interested in the event and want values */ private Set<Long> interestedClients; @@ -385,7 +379,7 @@ public class FilterRoutingInfo implements VersionedDataSerializable { * routing, so there is no need to deserialize the routings for other members */ private void deserialize() { - try (ByteArrayDataInput dis = new ByteArrayDataInput(myData, myDataVersion)) { + try (ByteArrayDataInput dis = new ByteArrayDataInput(myData)) { boolean hasCQs = dis.readBoolean(); if (hasCQs) { int numEntries = InternalDataSerializer.readArrayLength(dis);