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);

Reply via email to