geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kl...@apache.org
Subject [3/5] geode git commit: GEODE-2929: remove final from internal classes and tests
Date Mon, 15 May 2017 22:09:10 GMT
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/InitialImageOperation.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InitialImageOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InitialImageOperation.java
index d6dc98f..fb5f0cf 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/InitialImageOperation.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InitialImageOperation.java
@@ -1454,8 +1454,7 @@ public class InitialImageOperation {
   /**
    * This is the message that initiates a request for an image
    */
-  public static final class RequestImageMessage extends DistributionMessage
-      implements MessageWithReply {
+  public static class RequestImageMessage extends DistributionMessage implements MessageWithReply {
 
     /**
      * a version vector is transmitted with the request if we are merely synchronizing with an
@@ -2142,7 +2141,7 @@ public class InitialImageOperation {
   /**
    * This is the message thats sent to get Filter information.
    */
-  public static final class RequestFilterInfoMessage extends DistributionMessage
+  public static class RequestFilterInfoMessage extends DistributionMessage
       implements MessageWithReply {
 
     /**
@@ -2409,8 +2408,7 @@ public class InitialImageOperation {
   /**
    * This is the message thats sent to get RVV from GII provider.
    */
-  public static final class RequestRVVMessage extends DistributionMessage
-      implements MessageWithReply {
+  public static class RequestRVVMessage extends DistributionMessage implements MessageWithReply {
 
     /**
      * Name of the region.
@@ -2540,7 +2538,7 @@ public class InitialImageOperation {
   /**
    * This is the message thats sent to get RVV from GII provider.
    */
-  public static final class RequestSyncMessage extends HighPriorityDistributionMessage {
+  public static class RequestSyncMessage extends HighPriorityDistributionMessage {
 
     /**
      * Name of the region.
@@ -2633,7 +2631,7 @@ public class InitialImageOperation {
 
   }
 
-  public static final class ImageReplyMessage extends ReplyMessage {
+  public static class ImageReplyMessage extends ReplyMessage {
     /** the next entries in this chunk. Null means abort. */
     protected List entries;
 
@@ -2857,7 +2855,7 @@ public class InitialImageOperation {
   /**
    * Represents a key/value pair returned from a peer as part of an {@link InitialImageOperation}
    */
-  public static final class Entry implements DataSerializableFixedID {
+  public static class Entry implements DataSerializableFixedID {
     /**
      * key for this entry. Null if "end of chunk" marker entry
      */

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/InternalRegionArguments.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InternalRegionArguments.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InternalRegionArguments.java
index ba9d1d8..58d1780 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/InternalRegionArguments.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InternalRegionArguments.java
@@ -34,7 +34,7 @@ import org.apache.geode.internal.cache.wan.AbstractGatewaySender;
  * 
  * @since GemFire 4.2.3
  */
-public final class InternalRegionArguments {
+public class InternalRegionArguments {
   private boolean isUsedForPartitionedRegionAdmin;
   private boolean isUsedForSerialGatewaySenderQueue;
   private boolean isUsedForParallelGatewaySenderQueue;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateOperation.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateOperation.java
index eceb194..30edda4 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateOperation.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateOperation.java
@@ -159,7 +159,7 @@ public class InvalidateOperation extends DistributedCacheOperation {
     }
   }
 
-  public static final class InvalidateWithContextMessage extends InvalidateMessage {
+  public static class InvalidateWithContextMessage extends InvalidateMessage {
     transient ClientProxyMembershipID context;
 
     @Override

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateRegionOperation.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateRegionOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateRegionOperation.java
index 24fedb6..9339456 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateRegionOperation.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateRegionOperation.java
@@ -55,7 +55,7 @@ public class InvalidateRegionOperation extends DistributedCacheOperation {
     return false;
   }
 
-  public static final class InvalidateRegionMessage extends CacheOperationMessage {
+  public static class InvalidateRegionMessage extends CacheOperationMessage {
 
     protected EventID eventID;
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/Node.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/Node.java b/geode-core/src/main/java/org/apache/geode/internal/cache/Node.java
index e2b5f1c..8062d26 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/Node.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/Node.java
@@ -38,7 +38,7 @@ import org.apache.geode.distributed.internal.membership.InternalDistributedMembe
  * advertising that it never should receive a request to rebalance.
  * 
  */
-public final class Node extends ExternalizableDSFID {
+public class Node extends ExternalizableDSFID {
   private InternalDistributedMember memberId;
 
   public static final int NONE = 0;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/OpType.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/OpType.java b/geode-core/src/main/java/org/apache/geode/internal/cache/OpType.java
index ff36a57..4137af4 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/OpType.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/OpType.java
@@ -23,7 +23,7 @@ package org.apache.geode.internal.cache;
  * 
  * @since GemFire 6.6
  */
-public final class OpType {
+public class OpType {
 
   private OpType() {}
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/PRQueryProcessor.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PRQueryProcessor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PRQueryProcessor.java
index 0745975..0be8cf1 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/PRQueryProcessor.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PRQueryProcessor.java
@@ -480,7 +480,7 @@ public class PRQueryProcessor {
   /**
    * Status token placed in results stream to track completion of query results for a given bucket
    */
-  public static final class EndOfBucket implements DataSerializableFixedID {
+  public static class EndOfBucket implements DataSerializableFixedID {
 
     private int bucketId;
 
@@ -525,7 +525,7 @@ public class PRQueryProcessor {
    * 
    */
   @SuppressWarnings("synthetic-access")
-  private final class QueryTask implements Callable {
+  private class QueryTask implements Callable {
     private final DefaultQuery query;
     private final Object[] parameters;
     private final PartitionedRegionDataStore _prDs;
@@ -574,7 +574,7 @@ public class PRQueryProcessor {
      * Encapsulates the result for the query on the bucket.
      * 
      */
-    private final class BucketQueryResult {
+    private class BucketQueryResult {
 
       private int _buk;
       private Exception _ex = null;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/PreferBytesCachedDeserializable.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PreferBytesCachedDeserializable.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PreferBytesCachedDeserializable.java
index 428c982..c5ccd5b 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/PreferBytesCachedDeserializable.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PreferBytesCachedDeserializable.java
@@ -33,7 +33,7 @@ import org.apache.geode.internal.lang.StringUtils;
  * @since GemFire 5.0.2
  *
  */
-public final class PreferBytesCachedDeserializable
+public class PreferBytesCachedDeserializable
     implements CachedDeserializable, DataSerializableFixedID {
 
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/ProxyBucketRegion.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ProxyBucketRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ProxyBucketRegion.java
index 9d4b5e2..413a1f6 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/ProxyBucketRegion.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ProxyBucketRegion.java
@@ -57,7 +57,7 @@ import org.apache.geode.internal.logging.LogService;
  * 
  * @since GemFire 5.1
  */
-public final class ProxyBucketRegion implements Bucket {
+public class ProxyBucketRegion implements Bucket {
   private static final Logger logger = LogService.getLogger();
 
   private final int serialNumber;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteContainsKeyValueMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteContainsKeyValueMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteContainsKeyValueMessage.java
index debdfd2..49f3d6c 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteContainsKeyValueMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteContainsKeyValueMessage.java
@@ -45,7 +45,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
  * 
  * @since GemFire 6.5
  */
-public final class RemoteContainsKeyValueMessage extends RemoteOperationMessageWithDirectReply {
+public class RemoteContainsKeyValueMessage extends RemoteOperationMessageWithDirectReply {
   private static final Logger logger = LogService.getLogger();
 
   private boolean valueCheck;
@@ -164,7 +164,7 @@ public final class RemoteContainsKeyValueMessage extends RemoteOperationMessageW
     return flags;
   }
 
-  public static final class RemoteContainsKeyValueReplyMessage extends ReplyMessage {
+  public static class RemoteContainsKeyValueReplyMessage extends ReplyMessage {
 
     /** Propagated exception from remote node to operation initiator */
     private boolean containsKeyValue;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteFetchEntryMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteFetchEntryMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteFetchEntryMessage.java
index ea26745..913836a 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteFetchEntryMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteFetchEntryMessage.java
@@ -53,7 +53,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
  * 
  * @since GemFire 5.1
  */
-public final class RemoteFetchEntryMessage extends RemoteOperationMessage {
+public class RemoteFetchEntryMessage extends RemoteOperationMessage {
   private static final Logger logger = LogService.getLogger();
 
   private Object key;
@@ -172,7 +172,7 @@ public final class RemoteFetchEntryMessage extends RemoteOperationMessage {
    * 
    * @since GemFire 5.0
    */
-  public static final class FetchEntryReplyMessage extends ReplyMessage {
+  public static class FetchEntryReplyMessage extends ReplyMessage {
     /** Propagated exception from remote node to operation initiator */
     private EntrySnapshot value;
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteFetchVersionMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteFetchVersionMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteFetchVersionMessage.java
index f0ef305..e2125ab 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteFetchVersionMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteFetchVersionMessage.java
@@ -47,7 +47,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
  * 
  * @since GemFire 7.0
  */
-public final class RemoteFetchVersionMessage extends RemoteOperationMessage {
+public class RemoteFetchVersionMessage extends RemoteOperationMessage {
 
   private static final Logger logger = LogService.getLogger();
 
@@ -144,7 +144,7 @@ public final class RemoteFetchVersionMessage extends RemoteOperationMessage {
    * This message is used to send a reply for RemoteFetchVersionMessage.
    * 
    */
-  public static final class FetchVersionReplyMessage extends ReplyMessage {
+  public static class FetchVersionReplyMessage extends ReplyMessage {
     private VersionTag tag;
 
     /** for deserialization */

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteGetMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteGetMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteGetMessage.java
index 927697b..c72bd58 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteGetMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteGetMessage.java
@@ -57,7 +57,7 @@ import org.apache.geode.internal.util.BlobHelper;
  * 
  * @since GemFire 6.5
  */
-public final class RemoteGetMessage extends RemoteOperationMessageWithDirectReply {
+public class RemoteGetMessage extends RemoteOperationMessageWithDirectReply {
   private static final Logger logger = LogService.getLogger();
 
   private Object key;
@@ -214,7 +214,7 @@ public final class RemoteGetMessage extends RemoteOperationMessageWithDirectRepl
    * 
    * @since GemFire 6.5
    */
-  public static final class GetReplyMessage extends ReplyMessage {
+  public static class GetReplyMessage extends ReplyMessage {
     /**
      * The raw value in the cache which may be serialized to the output stream, if it is NOT already
      * a byte array

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteInvalidateMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteInvalidateMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteInvalidateMessage.java
index 1af51e8..eea654d 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteInvalidateMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteInvalidateMessage.java
@@ -54,7 +54,7 @@ import org.apache.geode.internal.offheap.annotations.Released;
 import static org.apache.geode.internal.cache.DistributedCacheOperation.VALUE_IS_BYTES;
 import static org.apache.geode.internal.cache.DistributedCacheOperation.VALUE_IS_SERIALIZED_OBJECT;
 
-public final class RemoteInvalidateMessage extends RemoteDestroyMessage {
+public class RemoteInvalidateMessage extends RemoteDestroyMessage {
 
   private static final Logger logger = LogService.getLogger();
 
@@ -261,7 +261,7 @@ public final class RemoteInvalidateMessage extends RemoteDestroyMessage {
   }
 
 
-  public static final class InvalidateReplyMessage extends ReplyMessage {
+  public static class InvalidateReplyMessage extends ReplyMessage {
     private VersionTag versionTag;
 
     private static final byte HAS_VERSION = 0x01;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/RemotePutAllMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RemotePutAllMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RemotePutAllMessage.java
index dc0f25c..c491acb 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/RemotePutAllMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RemotePutAllMessage.java
@@ -65,7 +65,7 @@ import org.apache.geode.internal.offheap.annotations.Released;
  *
  * @since GemFire 6.5
  */
-public final class RemotePutAllMessage extends RemoteOperationMessageWithDirectReply {
+public class RemotePutAllMessage extends RemoteOperationMessageWithDirectReply {
   private static final Logger logger = LogService.getLogger();
 
   private PutAllEntryData[] putAllData;
@@ -439,7 +439,7 @@ public final class RemotePutAllMessage extends RemoteOperationMessageWithDirectR
     }
   }
 
-  public static final class PutAllReplyMessage extends ReplyMessage {
+  public static class PutAllReplyMessage extends ReplyMessage {
     /** Result of the PutAll operation */
     // private PutAllResponseData[] responseData;
     private VersionedObjectList versions;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/RemotePutMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RemotePutMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RemotePutMessage.java
index acf77ba..95e49c8 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/RemotePutMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RemotePutMessage.java
@@ -66,7 +66,7 @@ import static org.apache.geode.internal.offheap.annotations.OffHeapIdentifier.EN
  *
  * @since GemFire 6.5
  */
-public final class RemotePutMessage extends RemoteOperationMessageWithDirectReply
+public class RemotePutMessage extends RemoteOperationMessageWithDirectReply
     implements NewValueImporter, OldValueImporter {
   private static final Logger logger = LogService.getLogger();
 
@@ -776,7 +776,7 @@ public final class RemotePutMessage extends RemoteOperationMessageWithDirectRepl
     this.internalDs = internalDs;
   }
 
-  public static final class PutReplyMessage extends ReplyMessage implements OldValueImporter {
+  public static class PutReplyMessage extends ReplyMessage implements OldValueImporter {
 
     static final byte FLAG_RESULT = 0x01;
     static final byte FLAG_HASVERSION = 0x02;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteRegionOperation.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteRegionOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteRegionOperation.java
index 4755fcf..b998fdf 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteRegionOperation.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteRegionOperation.java
@@ -42,7 +42,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
  * 
  * @since GemFire 7.0
  */
-public final class RemoteRegionOperation extends RemoteOperationMessageWithDirectReply {
+public class RemoteRegionOperation extends RemoteOperationMessageWithDirectReply {
   private static final Logger logger = LogService.getLogger();
 
   private enum Operation {
@@ -135,7 +135,7 @@ public final class RemoteRegionOperation extends RemoteOperationMessageWithDirec
     out.writeByte(this.op.ordinal());
   }
 
-  public static final class RemoteRegionOperationReplyMessage extends ReplyMessage {
+  public static class RemoteRegionOperationReplyMessage extends ReplyMessage {
 
     /**
      * Empty constructor to conform to DataSerializable interface

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteRemoveAllMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteRemoveAllMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteRemoveAllMessage.java
index d30e8c1..a9b8c1a 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteRemoveAllMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RemoteRemoveAllMessage.java
@@ -65,7 +65,7 @@ import org.apache.geode.internal.offheap.annotations.Released;
  *
  * @since GemFire 8.1
  */
-public final class RemoteRemoveAllMessage extends RemoteOperationMessageWithDirectReply {
+public class RemoteRemoveAllMessage extends RemoteOperationMessageWithDirectReply {
   private static final Logger logger = LogService.getLogger();
 
   private RemoveAllEntryData[] removeAllData;
@@ -429,7 +429,7 @@ public final class RemoteRemoveAllMessage extends RemoteOperationMessageWithDire
     }
   }
 
-  public static final class RemoveAllReplyMessage extends ReplyMessage {
+  public static class RemoveAllReplyMessage extends ReplyMessage {
     /** Result of the RemoveAll operation */
     private VersionedObjectList versions;
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/RoleEventImpl.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RoleEventImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RoleEventImpl.java
index 9b2c5b1..bb015bf 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/RoleEventImpl.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RoleEventImpl.java
@@ -31,7 +31,7 @@ import org.apache.geode.distributed.internal.membership.InternalRole;
  *
  * @since GemFire 5.0
  */
-public final class RoleEventImpl extends RegionEventImpl implements RoleEvent, DataSerializable {
+public class RoleEventImpl extends RegionEventImpl implements RoleEvent, DataSerializable {
 
   private static final long serialVersionUID = 1306615015229258945L;
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/SearchLoadAndWriteProcessor.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/SearchLoadAndWriteProcessor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/SearchLoadAndWriteProcessor.java
index 34f6b73..4e30a34 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/SearchLoadAndWriteProcessor.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/SearchLoadAndWriteProcessor.java
@@ -1346,7 +1346,7 @@ public class SearchLoadAndWriteProcessor implements MembershipListener {
    * A QueryMessage is broadcast to every node that has the region defined, to find out who has a
    * valid copy of the requested object.
    */
-  public static final class QueryMessage extends SerialDistributionMessage {
+  public static class QueryMessage extends SerialDistributionMessage {
 
     /**
      * The object id of the processor object on the initiator node. This will be communicated back
@@ -1593,7 +1593,7 @@ public class SearchLoadAndWriteProcessor implements MembershipListener {
    * The ResponseMessage is a reply to a QueryMessage, and contains the object's value, if it is
    * below the byte limit, otherwise an indication of whether the sender has the value.
    */
-  public static final class ResponseMessage extends HighPriorityDistributionMessage {
+  public static class ResponseMessage extends HighPriorityDistributionMessage {
 
     private Object key;
 
@@ -1722,7 +1722,7 @@ public class SearchLoadAndWriteProcessor implements MembershipListener {
 
   /********************* NetSearchRequestMessage ***************************************/
 
-  public static final class NetSearchRequestMessage extends PooledDistributionMessage {
+  public static class NetSearchRequestMessage extends PooledDistributionMessage {
 
     /**
      * The object id of the processor object on the initiator node. This will be communicated back
@@ -1949,7 +1949,7 @@ public class SearchLoadAndWriteProcessor implements MembershipListener {
    * The NetSearchReplyMessage is a reply to a NetSearchRequestMessage, and contains the object's
    * value.
    */
-  public static final class NetSearchReplyMessage extends HighPriorityDistributionMessage {
+  public static class NetSearchReplyMessage extends HighPriorityDistributionMessage {
     private static final byte SERIALIZED = 0x01;
     private static final byte REQUESTOR_TIMEOUT = 0x02;
     private static final byte AUTHORATIVE = 0x04;
@@ -2105,7 +2105,7 @@ public class SearchLoadAndWriteProcessor implements MembershipListener {
 
   /******************************** NetLoadRequestMessage **********************/
 
-  public static final class NetLoadRequestMessage extends PooledDistributionMessage {
+  public static class NetLoadRequestMessage extends PooledDistributionMessage {
 
     /**
      * The object id of the processor object on the initiator node. This will be communicated back
@@ -2282,7 +2282,7 @@ public class SearchLoadAndWriteProcessor implements MembershipListener {
   /**
    * The NetLoadReplyMessage is a reply to a RequestMessage, and contains the object's value.
    */
-  public static final class NetLoadReplyMessage extends HighPriorityDistributionMessage {
+  public static class NetLoadReplyMessage extends HighPriorityDistributionMessage {
 
     /** The gemfire id of the SearchLoadAndWrite object waiting for response */
     private int processorId;
@@ -2386,7 +2386,7 @@ public class SearchLoadAndWriteProcessor implements MembershipListener {
 
   /********************* NetWriteRequestMessage *******************************/
 
-  public static final class NetWriteRequestMessage extends PooledDistributionMessage {
+  public static class NetWriteRequestMessage extends PooledDistributionMessage {
 
     /**
      * The object id of the processor object on the initiator node. This will be communicated back
@@ -2587,7 +2587,7 @@ public class SearchLoadAndWriteProcessor implements MembershipListener {
    * The NetWriteReplyMessage is a reply to a NetWriteRequestMessage, and contains the success code
    * or exception that is propagated back to the requestor
    */
-  public static final class NetWriteReplyMessage extends HighPriorityDistributionMessage {
+  public static class NetWriteReplyMessage extends HighPriorityDistributionMessage {
 
     /** The gemfire id of the SearchLoadAndWrite object waiting for response */
     private int processorId;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/StateFlushOperation.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/StateFlushOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/StateFlushOperation.java
index a8f1edc..3ad1137 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/StateFlushOperation.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/StateFlushOperation.java
@@ -272,8 +272,7 @@ public class StateFlushOperation {
    * @see StateFlushOperation.StateStabilizedMessage
    *
    */
-  public static final class StateMarkerMessage extends DistributionMessage
-      implements MessageWithReply {
+  public static class StateMarkerMessage extends DistributionMessage implements MessageWithReply {
     /** roll the membership version to force flushing of new ops */
     public boolean flushNewOps;
     /** the member acting as the relay point */
@@ -525,7 +524,7 @@ public class StateFlushOperation {
    * @see StateFlushOperation.StateMarkerMessage
    * @since GemFire 5.0.1
    */
-  public static final class StateStabilizationMessage extends SerialDistributionMessage {
+  public static class StateStabilizationMessage extends SerialDistributionMessage {
     /** the member that requested StateStabilizedMessages */
     protected DistributedMember requestingMember;
     /** the processor id for the requesting member */
@@ -673,7 +672,7 @@ public class StateFlushOperation {
    * @since GemFire 5.0.1
    *
    */
-  public static final class StateStabilizedMessage extends ReplyMessage {
+  public static class StateStabilizedMessage extends ReplyMessage {
     /** the member for whom this ack is being sent */
     protected DistributedMember sendingMember;
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryState.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryState.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryState.java
index f090ba4..e7bd20d 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryState.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryState.java
@@ -1929,7 +1929,7 @@ public class TXEntryState implements Releasable {
    * 
    * @since GemFire 5.0
    */
-  public final class TxEntryEventImpl extends EntryEventImpl implements Comparable {
+  public class TxEntryEventImpl extends EntryEventImpl implements Comparable {
     /**
      * Creates a local tx entry event
      */

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/TXId.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXId.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXId.java
index db74765..32fe284 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXId.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXId.java
@@ -34,7 +34,7 @@ import org.apache.geode.distributed.internal.membership.*;
  * @see TXManagerImpl#begin
  * @see org.apache.geode.cache.CacheTransactionManager#getTransactionId
  */
-public final class TXId extends ExternalizableDSFID implements TransactionId {
+public class TXId extends ExternalizableDSFID implements TransactionId {
   /** The domain of a transaction, currently the VM's unique identifier */
   private InternalDistributedMember memberId;
   /** Per unique identifier within the transactions memberId */

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/TXRemoteCommitMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXRemoteCommitMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXRemoteCommitMessage.java
index 6a1eeed..c229997 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXRemoteCommitMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXRemoteCommitMessage.java
@@ -127,7 +127,7 @@ public class TXRemoteCommitMessage extends TXMessage {
    * 
    * @since GemFire 6.5
    */
-  public static final class TXRemoteCommitReplyMessage extends ReplyMessage {
+  public static class TXRemoteCommitReplyMessage extends ReplyMessage {
 
     private transient TXCommitMessage commitMessage;
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/Token.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/Token.java b/geode-core/src/main/java/org/apache/geode/internal/cache/Token.java
index 54f57da..9917533 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/Token.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/Token.java
@@ -303,7 +303,7 @@ public abstract class Token {
   }
 
   /** Token used in StreamingOperation, StreamingPartitionOperation */
-  public static final class EndOfStream extends Token implements DataSerializableFixedID {
+  public static class EndOfStream extends Token implements DataSerializableFixedID {
     public EndOfStream() {}
 
     @Override

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/UnsharedImageState.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/UnsharedImageState.java b/geode-core/src/main/java/org/apache/geode/internal/cache/UnsharedImageState.java
index 78a4c99..8b4c380 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/UnsharedImageState.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/UnsharedImageState.java
@@ -256,7 +256,7 @@ public class UnsharedImageState implements ImageState {
   }
 
   /** tracks RVV versions applied to the region during GII */
-  private static final class VersionTagEntryImpl implements ImageState.VersionTagEntry {
+  private static class VersionTagEntryImpl implements ImageState.VersionTagEntry {
     Object key;
     VersionSource member;
     long regionVersion;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateAttributesProcessor.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateAttributesProcessor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateAttributesProcessor.java
index 53c3832..8159d9c 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateAttributesProcessor.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateAttributesProcessor.java
@@ -258,7 +258,7 @@ public class UpdateAttributesProcessor {
   }
 
 
-  public static final class UpdateAttributesMessage extends HighPriorityDistributionMessage
+  public static class UpdateAttributesMessage extends HighPriorityDistributionMessage
       implements MessageWithReply {
 
     protected String adviseePath;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateOperation.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateOperation.java
index 1afae86..cd41201 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateOperation.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateOperation.java
@@ -496,7 +496,7 @@ public class UpdateOperation extends AbstractUpdateOperation {
     }
   }
 
-  public static final class UpdateWithContextMessage extends UpdateMessage {
+  public static class UpdateWithContextMessage extends UpdateMessage {
 
     protected transient ClientProxyMembershipID clientID;
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/VMCachedDeserializable.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMCachedDeserializable.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMCachedDeserializable.java
index a2894e3..c559b5d 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMCachedDeserializable.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMCachedDeserializable.java
@@ -34,7 +34,7 @@ import org.apache.geode.pdx.PdxInstance;
  * then on keep a reference to the deserialized form. So it "prefers deserialization".
  *
  */
-public final class VMCachedDeserializable implements CachedDeserializable, DataSerializableFixedID {
+public class VMCachedDeserializable implements CachedDeserializable, DataSerializableFixedID {
 
   /** The cached value */
   private volatile Object value;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/VMLRURegionMap.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMLRURegionMap.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMLRURegionMap.java
index 93dfa82..65a4bfd 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMLRURegionMap.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMLRURegionMap.java
@@ -26,7 +26,7 @@ import org.apache.geode.internal.cache.lru.*;
  *
  *
  */
-final class VMLRURegionMap extends AbstractLRURegionMap {
+class VMLRURegionMap extends AbstractLRURegionMap {
 
   VMLRURegionMap(Object owner, Attributes attr, InternalRegionArguments internalRegionArgs) {
     super(internalRegionArgs);

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/VMRegionMap.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMRegionMap.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMRegionMap.java
index c1cfb14..989a112 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMRegionMap.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMRegionMap.java
@@ -22,7 +22,7 @@ package org.apache.geode.internal.cache;
  *
  *
  */
-final class VMRegionMap extends AbstractRegionMap {
+class VMRegionMap extends AbstractRegionMap {
 
   VMRegionMap(Object owner, Attributes attr, InternalRegionArguments internalRegionArgs) {
     super(internalRegionArgs);

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionResultSender.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionResultSender.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionResultSender.java
index d0b7bb8..d0a0b88 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionResultSender.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionResultSender.java
@@ -33,7 +33,7 @@ import org.apache.geode.internal.logging.log4j.LocalizedMessage;
  * 
  *
  */
-public final class MemberFunctionResultSender implements InternalResultSender {
+public class MemberFunctionResultSender implements InternalResultSender {
 
   private static final Logger logger = LogService.getLogger();
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/execute/NoResult.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/NoResult.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/NoResult.java
index 19b5421..3694e98 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/NoResult.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/NoResult.java
@@ -36,7 +36,7 @@ import org.apache.geode.internal.i18n.LocalizedStrings;
  * @see Function#hasResult()
  * 
  */
-public final class NoResult implements ResultCollector, Serializable {
+public class NoResult implements ResultCollector, Serializable {
 
   private static final long serialVersionUID = -4901369422864228848L;
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionResultSender.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionResultSender.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionResultSender.java
index 9aa8262..5fb1f78 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionResultSender.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionResultSender.java
@@ -40,7 +40,7 @@ import org.apache.geode.internal.logging.log4j.LocalizedMessage;
  * 
  */
 
-public final class PartitionedRegionFunctionResultSender implements InternalResultSender {
+public class PartitionedRegionFunctionResultSender implements InternalResultSender {
 
   private static final Logger logger = LogService.getLogger();
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/ha/QueueRemovalMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/QueueRemovalMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/QueueRemovalMessage.java
index 7879538..357d18c 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/QueueRemovalMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/QueueRemovalMessage.java
@@ -44,7 +44,7 @@ import org.apache.geode.internal.logging.log4j.LocalizedMessage;
  * that have been dispatched by this node. The messages are received by other nodes and the
  * processing is handed over to an executor
  */
-public final class QueueRemovalMessage extends PooledDistributionMessage {
+public class QueueRemovalMessage extends PooledDistributionMessage {
   private static final Logger logger = LogService.getLogger();
 
   /**

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockBatch.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockBatch.java b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockBatch.java
index 2a2a37c..c762158 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockBatch.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockBatch.java
@@ -33,7 +33,7 @@ import org.apache.geode.distributed.internal.membership.*;
  * Adapts multiple TXRegionLockRequests to one DLockBatch for DLock to use.
  *
  */
-public final class TXLockBatch implements DLockBatch, DataSerializableFixedID {
+public class TXLockBatch implements DLockBatch, DataSerializableFixedID {
 
   /** Identifies the batch as a single entity */
   private TXLockIdImpl txLockId;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockIdImpl.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockIdImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockIdImpl.java
index 848088b..4d067e4 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockIdImpl.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockIdImpl.java
@@ -27,7 +27,7 @@ import org.apache.geode.distributed.internal.membership.*;
  * Identifies a group of transaction locks.
  *
  */
-public final class TXLockIdImpl implements TXLockId, DataSerializableFixedID {
+public class TXLockIdImpl implements TXLockId, DataSerializableFixedID {
 
   private static final long serialVersionUID = 8579214625084490134L;
   /** DistributionManager id for this member */

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockUpdateParticipantsMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockUpdateParticipantsMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockUpdateParticipantsMessage.java
index bd1ea6d..5d03abd 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockUpdateParticipantsMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockUpdateParticipantsMessage.java
@@ -46,7 +46,7 @@ import java.util.Set;
  * 
  * @since GemFire 4.1.1
  */
-public final class TXLockUpdateParticipantsMessage extends PooledDistributionMessage
+public class TXLockUpdateParticipantsMessage extends PooledDistributionMessage
     implements MessageWithReply {
 
   private transient TXLockId txLockId;
@@ -144,7 +144,7 @@ public final class TXLockUpdateParticipantsMessage extends PooledDistributionMes
   /**
    * The simple reply message that the sender waits for
    */
-  public static final class TXLockUpdateParticipantsReplyMessage extends ReplyMessage {
+  public static class TXLockUpdateParticipantsReplyMessage extends ReplyMessage {
 
     @Override
     public int getDSFID() {

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXOriginatorRecoveryProcessor.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXOriginatorRecoveryProcessor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXOriginatorRecoveryProcessor.java
index 6deae63..0dc75ff 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXOriginatorRecoveryProcessor.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXOriginatorRecoveryProcessor.java
@@ -120,7 +120,7 @@ public class TXOriginatorRecoveryProcessor extends ReplyProcessor21 {
   // -------------------------------------------------------------------------
   // TXOriginatorRecoveryMessage
   // -------------------------------------------------------------------------
-  public static final class TXOriginatorRecoveryMessage extends PooledDistributionMessage
+  public static class TXOriginatorRecoveryMessage extends PooledDistributionMessage
       implements MessageWithReply {
 
     /** The transaction lock for which the originator orphaned */
@@ -266,7 +266,7 @@ public class TXOriginatorRecoveryProcessor extends ReplyProcessor21 {
   // -------------------------------------------------------------------------
   // TXOriginatorRecoveryReplyMessage
   // -------------------------------------------------------------------------
-  public static final class TXOriginatorRecoveryReplyMessage extends ReplyMessage {
+  public static class TXOriginatorRecoveryReplyMessage extends ReplyMessage {
 
     /** The transaction lock for which the originator orphaned */
     protected TXLockId txLockId; // only for the toString

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/lru/LRUCapacityController.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/lru/LRUCapacityController.java b/geode-core/src/main/java/org/apache/geode/internal/cache/lru/LRUCapacityController.java
index 98e007c..f1972a6 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/lru/LRUCapacityController.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/lru/LRUCapacityController.java
@@ -51,7 +51,7 @@ import java.util.*;
  *
  * @since GemFire 2.0.2
  */
-public final class LRUCapacityController extends LRUAlgorithm implements Declarable {
+public class LRUCapacityController extends LRUAlgorithm implements Declarable {
 
   private static final long serialVersionUID = -4383074909189355938L;
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/lru/MemLRUCapacityController.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/lru/MemLRUCapacityController.java b/geode-core/src/main/java/org/apache/geode/internal/cache/lru/MemLRUCapacityController.java
index 1694f1b..17673a3 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/lru/MemLRUCapacityController.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/lru/MemLRUCapacityController.java
@@ -74,7 +74,7 @@ import org.apache.geode.internal.i18n.LocalizedStrings;
  *
  * @since GemFire 2.0.2
  */
-public final class MemLRUCapacityController extends LRUAlgorithm implements Declarable {
+public class MemLRUCapacityController extends LRUAlgorithm implements Declarable {
 
   private static final long serialVersionUID = 6364183985590572514L;
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/lru/NewLRUClockHand.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/lru/NewLRUClockHand.java b/geode-core/src/main/java/org/apache/geode/internal/cache/lru/NewLRUClockHand.java
index bbfef42..d9d6be1 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/lru/NewLRUClockHand.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/lru/NewLRUClockHand.java
@@ -408,7 +408,7 @@ public class NewLRUClockHand {
   protected static class HeadLock extends Object {
   }
 
-  private static final class GuardNode implements LRUClockNode {
+  private static class GuardNode implements LRUClockNode {
 
     private LRUClockNode next;
     LRUClockNode prev;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/AllBucketProfilesUpdateMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/AllBucketProfilesUpdateMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/AllBucketProfilesUpdateMessage.java
index 8b4cea7..02faa25 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/AllBucketProfilesUpdateMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/AllBucketProfilesUpdateMessage.java
@@ -42,7 +42,7 @@ import org.apache.geode.internal.logging.LogService;
  * 
  * @since GemFire 6.6
  */
-public final class AllBucketProfilesUpdateMessage extends DistributionMessage
+public class AllBucketProfilesUpdateMessage extends DistributionMessage
     implements MessageWithReply {
   private static final Logger logger = LogService.getLogger();
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BecomePrimaryBucketMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BecomePrimaryBucketMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BecomePrimaryBucketMessage.java
index eeb3704..31b8af2 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BecomePrimaryBucketMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BecomePrimaryBucketMessage.java
@@ -158,7 +158,7 @@ public class BecomePrimaryBucketMessage extends PartitionMessage {
     out.writeBoolean(this.isRebalance);
   }
 
-  public static final class BecomePrimaryBucketReplyMessage extends ReplyMessage {
+  public static class BecomePrimaryBucketReplyMessage extends ReplyMessage {
 
     static final byte NOT_SECONDARY = 0;
     static final byte OK = 1;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BucketBackupMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BucketBackupMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BucketBackupMessage.java
index 122791d..8d164c8 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BucketBackupMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BucketBackupMessage.java
@@ -37,7 +37,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
  * 
  * @since GemFire 5.0
  */
-public final class BucketBackupMessage extends PartitionMessage {
+public class BucketBackupMessage extends PartitionMessage {
 
   private static final Logger logger = LogService.getLogger();
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BucketProfileUpdateMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BucketProfileUpdateMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BucketProfileUpdateMessage.java
index e413033..1d92687 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BucketProfileUpdateMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BucketProfileUpdateMessage.java
@@ -42,8 +42,7 @@ import org.apache.geode.internal.logging.LogService;
  * 
  * @since GemFire 5.1
  */
-public final class BucketProfileUpdateMessage extends DistributionMessage
-    implements MessageWithReply {
+public class BucketProfileUpdateMessage extends DistributionMessage implements MessageWithReply {
   private static final Logger logger = LogService.getLogger();
 
   private static final long serialVersionUID = 1L;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BucketSizeMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BucketSizeMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BucketSizeMessage.java
index ed17740..bd83c1b 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BucketSizeMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/BucketSizeMessage.java
@@ -46,7 +46,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
  * @since GemFire 5.0
  */
 
-public final class BucketSizeMessage extends PartitionMessage {
+public class BucketSizeMessage extends PartitionMessage {
   private static final Logger logger = LogService.getLogger();
 
   /** The list of buckets whose size is needed, if null, then all buckets */
@@ -135,7 +135,7 @@ public final class BucketSizeMessage extends PartitionMessage {
     out.writeInt(this.bucketId); // fix for bug 38228
   }
 
-  public static final class BucketSizeReplyMessage extends HighPriorityDistributionMessage {
+  public static class BucketSizeReplyMessage extends HighPriorityDistributionMessage {
     /** The shared obj id of the ReplyProcessor */
     private int processorId;
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/ContainsKeyValueMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/ContainsKeyValueMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/ContainsKeyValueMessage.java
index d6422c2..709cb13 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/ContainsKeyValueMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/ContainsKeyValueMessage.java
@@ -44,7 +44,7 @@ import org.apache.geode.internal.logging.LogService;
 import org.apache.geode.internal.logging.log4j.LocalizedMessage;
 import org.apache.geode.internal.logging.log4j.LogMarker;
 
-public final class ContainsKeyValueMessage extends PartitionMessageWithDirectReply {
+public class ContainsKeyValueMessage extends PartitionMessageWithDirectReply {
   private static final Logger logger = LogService.getLogger();
 
   private boolean valueCheck;
@@ -169,7 +169,7 @@ public final class ContainsKeyValueMessage extends PartitionMessageWithDirectRep
     out.writeInt(this.bucketId.intValue());
   }
 
-  public static final class ContainsKeyValueReplyMessage extends ReplyMessage {
+  public static class ContainsKeyValueReplyMessage extends ReplyMessage {
 
     /** Propagated exception from remote node to operation initiator */
     private boolean containsKeyValue;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/CreateBucketMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/CreateBucketMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/CreateBucketMessage.java
index 744e013..962eb1a 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/CreateBucketMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/CreateBucketMessage.java
@@ -55,7 +55,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
  * @since GemFire 6.0
  *
  */
-public final class CreateBucketMessage extends PartitionMessage {
+public class CreateBucketMessage extends PartitionMessage {
   private static final Logger logger = LogService.getLogger();
 
   /** The key associated with the value that must be sent */
@@ -194,7 +194,7 @@ public final class CreateBucketMessage extends PartitionMessage {
    * 
    * @since GemFire 5.0
    */
-  public static final class CreateBucketReplyMessage extends ReplyMessage {
+  public static class CreateBucketReplyMessage extends ReplyMessage {
     private InternalDistributedMember primary;
 
     /**

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/CreateMissingBucketsTask.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/CreateMissingBucketsTask.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/CreateMissingBucketsTask.java
index e72e2cf..18503c5 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/CreateMissingBucketsTask.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/CreateMissingBucketsTask.java
@@ -24,7 +24,7 @@ import org.apache.geode.internal.cache.PartitionedRegion.RecoveryLock;
  * A task for creating buckets in a child colocated region that are present in the leader region.
  *
  */
-public final class CreateMissingBucketsTask extends RecoveryRunnable {
+public class CreateMissingBucketsTask extends RecoveryRunnable {
   public CreateMissingBucketsTask(PRHARedundancyProvider prhaRedundancyProvider) {
     super(prhaRedundancyProvider);
   }

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DeposePrimaryBucketMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DeposePrimaryBucketMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DeposePrimaryBucketMessage.java
index f305fa8..f1633bd 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DeposePrimaryBucketMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DeposePrimaryBucketMessage.java
@@ -134,7 +134,7 @@ public class DeposePrimaryBucketMessage extends PartitionMessage {
     out.writeInt(this.bucketId);
   }
 
-  public static final class DeposePrimaryBucketReplyMessage extends ReplyMessage {
+  public static class DeposePrimaryBucketReplyMessage extends ReplyMessage {
 
     /**
      * Empty constructor to conform to DataSerializable interface

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DestroyRegionOnDataStoreMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DestroyRegionOnDataStoreMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DestroyRegionOnDataStoreMessage.java
index 9bbc39d..1d2ab7b 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DestroyRegionOnDataStoreMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DestroyRegionOnDataStoreMessage.java
@@ -41,7 +41,7 @@ import org.apache.geode.internal.cache.PartitionedRegionDataStore;
  * 
  * @since GemFire 5.0
  */
-public final class DestroyRegionOnDataStoreMessage extends PartitionMessage {
+public class DestroyRegionOnDataStoreMessage extends PartitionMessage {
 
   private Object callbackArg;
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DumpAllPRConfigMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DumpAllPRConfigMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DumpAllPRConfigMessage.java
index 08daeb7..07b293b 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DumpAllPRConfigMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DumpAllPRConfigMessage.java
@@ -32,7 +32,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
  * 
  * @see org.apache.geode.internal.cache.PartitionedRegion#sendDumpAllPartitionedRegions()
  */
-public final class DumpAllPRConfigMessage extends PartitionMessage {
+public class DumpAllPRConfigMessage extends PartitionMessage {
   private static final Logger logger = LogService.getLogger();
 
   public DumpAllPRConfigMessage() {}

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DumpB2NRegion.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DumpB2NRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DumpB2NRegion.java
index 6314f2d..220c51f 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DumpB2NRegion.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DumpB2NRegion.java
@@ -54,7 +54,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
  * 
  * @see org.apache.geode.internal.cache.PartitionedRegion#sendDumpB2NRegionForBucket(int)
  */
-public final class DumpB2NRegion extends PartitionMessage {
+public class DumpB2NRegion extends PartitionMessage {
   private static final Logger logger = LogService.getLogger();
 
   private int bucketId;
@@ -167,7 +167,7 @@ public final class DumpB2NRegion extends PartitionMessage {
 
 
 
-  public static final class DumpB2NReplyMessage extends ReplyMessage {
+  public static class DumpB2NReplyMessage extends ReplyMessage {
     private PrimaryInfo primaryInfo;
 
     public DumpB2NReplyMessage() {}

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DumpBucketsMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DumpBucketsMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DumpBucketsMessage.java
index d924b69..b8bd629 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DumpBucketsMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/DumpBucketsMessage.java
@@ -36,7 +36,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
  * 
  * @see org.apache.geode.internal.cache.PartitionedRegion#dumpAllBuckets(boolean)
  */
-public final class DumpBucketsMessage extends PartitionMessage {
+public class DumpBucketsMessage extends PartitionMessage {
   private static final Logger logger = LogService.getLogger();
 
   boolean validateOnly;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchBulkEntriesMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchBulkEntriesMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchBulkEntriesMessage.java
index 41186ff..b767f6c 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchBulkEntriesMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchBulkEntriesMessage.java
@@ -63,7 +63,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
  * 
  * @since GemFire 8.0
  */
-public final class FetchBulkEntriesMessage extends PartitionMessage {
+public class FetchBulkEntriesMessage extends PartitionMessage {
   private static final Logger logger = LogService.getLogger();
 
   private HashSet<Integer> bucketIds;
@@ -174,7 +174,7 @@ public final class FetchBulkEntriesMessage extends PartitionMessage {
     DataSerializer.writePrimitiveBoolean(this.allowTombstones, out);
   }
 
-  public static final class FetchBulkEntriesReplyMessage extends ReplyMessage {
+  public static class FetchBulkEntriesReplyMessage extends ReplyMessage {
 
     /** Whether this message is the last of a series of chunk responses */
     boolean lastInSeries;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchEntriesMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchEntriesMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchEntriesMessage.java
index c7ca279..489ffba 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchEntriesMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchEntriesMessage.java
@@ -65,7 +65,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
 import org.apache.geode.internal.offheap.OffHeapHelper;
 import org.apache.geode.internal.util.ObjectIntProcedure;
 
-public final class FetchEntriesMessage extends PartitionMessage {
+public class FetchEntriesMessage extends PartitionMessage {
   private static final Logger logger = LogService.getLogger();
 
   private int bucketId;
@@ -150,7 +150,7 @@ public final class FetchEntriesMessage extends PartitionMessage {
     out.writeInt(this.bucketId);
   }
 
-  public static final class FetchEntriesReplyMessage extends ReplyMessage {
+  public static class FetchEntriesReplyMessage extends ReplyMessage {
 
     /** The bucket id */
     int bucketId;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchEntryMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchEntryMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchEntryMessage.java
index 301e154..664ebe7 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchEntryMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchEntryMessage.java
@@ -58,7 +58,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
  * 
  * @since GemFire 5.1
  */
-public final class FetchEntryMessage extends PartitionMessage {
+public class FetchEntryMessage extends PartitionMessage {
   private static final Logger logger = LogService.getLogger();
 
   private Object key;
@@ -218,7 +218,7 @@ public final class FetchEntryMessage extends PartitionMessage {
    * 
    * @since GemFire 5.0
    */
-  public static final class FetchEntryReplyMessage extends ReplyMessage {
+  public static class FetchEntryReplyMessage extends ReplyMessage {
     /** Propagated exception from remote node to operation initiator */
     private EntrySnapshot value;
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchKeysMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchKeysMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchKeysMessage.java
index e1c708a..67d81ef 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchKeysMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchKeysMessage.java
@@ -52,7 +52,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
 import org.apache.geode.internal.util.ObjectIntProcedure;
 
 
-public final class FetchKeysMessage extends PartitionMessage {
+public class FetchKeysMessage extends PartitionMessage {
   private static final Logger logger = LogService.getLogger();
 
   private Integer bucketId;
@@ -217,7 +217,7 @@ public final class FetchKeysMessage extends PartitionMessage {
     out.writeBoolean(this.allowTombstones);
   }
 
-  public static final class FetchKeysReplyMessage extends ReplyMessage {
+  public static class FetchKeysReplyMessage extends ReplyMessage {
     /** The number of the series */
     int seriesNum;
     /** The message number in the series */

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchPartitionDetailsMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchPartitionDetailsMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchPartitionDetailsMessage.java
index 5f4dec1..21dfa8d 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchPartitionDetailsMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchPartitionDetailsMessage.java
@@ -145,7 +145,7 @@ public class FetchPartitionDetailsMessage extends PartitionMessage {
     DataSerializer.writeObject(loadProbe, out);
   }
 
-  public static final class FetchPartitionDetailsReplyMessage extends ReplyMessage {
+  public static class FetchPartitionDetailsReplyMessage extends ReplyMessage {
 
     static final byte NO_PARTITION = 0;
     static final byte OK = 1;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FlushMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FlushMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FlushMessage.java
index 96d838d..34d530b 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FlushMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FlushMessage.java
@@ -48,7 +48,7 @@ import org.apache.geode.internal.logging.LogService;
  * 
  * @since GemFire 5.1
  */
-public final class FlushMessage extends SerialDistributionMessage implements MessageWithReply {
+public class FlushMessage extends SerialDistributionMessage implements MessageWithReply {
   private static final Logger logger = LogService.getLogger();
 
   private static final long serialVersionUID = 1L;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/GetMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/GetMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/GetMessage.java
index 1c2a6a7..0e3f74b 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/GetMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/GetMessage.java
@@ -64,7 +64,7 @@ import java.util.Set;
  * 
  * @since GemFire 5.0
  */
-public final class GetMessage extends PartitionMessageWithDirectReply {
+public class GetMessage extends PartitionMessageWithDirectReply {
   private static final Logger logger = LogService.getLogger();
 
   private Object key;
@@ -298,7 +298,7 @@ public final class GetMessage extends PartitionMessageWithDirectReply {
    * 
    * @since GemFire 5.0
    */
-  public static final class GetReplyMessage extends ReplyMessage {
+  public static class GetReplyMessage extends ReplyMessage {
     /**
      * The raw value in the cache which may be serialized to the output stream, if it is NOT already
      * a byte array

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/IdentityRequestMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/IdentityRequestMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/IdentityRequestMessage.java
index e8595fa..a99fd7a 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/IdentityRequestMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/IdentityRequestMessage.java
@@ -42,7 +42,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
  * 
  * @since GemFire 5.0
  */
-public final class IdentityRequestMessage extends DistributionMessage implements MessageWithReply {
+public class IdentityRequestMessage extends DistributionMessage implements MessageWithReply {
   private static final Logger logger = LogService.getLogger();
 
   private static final int UNINITIALIZED = -1;
@@ -166,7 +166,7 @@ public final class IdentityRequestMessage extends DistributionMessage implements
    * 
    * @since GemFire 5.0
    */
-  public static final class IdentityReplyMessage extends HighPriorityDistributionMessage {
+  public static class IdentityReplyMessage extends HighPriorityDistributionMessage {
     private int Id = UNINITIALIZED;
 
     /** The shared obj id of the ReplyProcessor */

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/IdentityUpdateMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/IdentityUpdateMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/IdentityUpdateMessage.java
index 3ac9ee0..419e083 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/IdentityUpdateMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/IdentityUpdateMessage.java
@@ -34,7 +34,7 @@ import org.apache.geode.internal.logging.LogService;
 import org.apache.geode.internal.logging.log4j.LogMarker;
 
 
-public final class IdentityUpdateMessage extends DistributionMessage implements MessageWithReply {
+public class IdentityUpdateMessage extends DistributionMessage implements MessageWithReply {
   private static final Logger logger = LogService.getLogger();
 
   private int processorId;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/IndexCreationMsg.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/IndexCreationMsg.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/IndexCreationMsg.java
index 86c47e7..c71aa40 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/IndexCreationMsg.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/IndexCreationMsg.java
@@ -546,7 +546,7 @@ public class IndexCreationMsg extends PartitionMessage {
    * 
    * 
    */
-  public static final class IndexCreationReplyMsg extends ReplyMessage {
+  public static class IndexCreationReplyMsg extends ReplyMessage {
 
     /** Index created or not. */
     private boolean result;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/InvalidateMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/InvalidateMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/InvalidateMessage.java
index 8db893a..00db87c 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/InvalidateMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/InvalidateMessage.java
@@ -53,7 +53,7 @@ import org.apache.geode.internal.logging.LogService;
 import org.apache.geode.internal.logging.log4j.LogMarker;
 import org.apache.geode.internal.offheap.annotations.Released;
 
-public final class InvalidateMessage extends DestroyMessage {
+public class InvalidateMessage extends DestroyMessage {
   private static final Logger logger = LogService.getLogger();
 
   /**
@@ -247,7 +247,7 @@ public final class InvalidateMessage extends DestroyMessage {
     return PR_INVALIDATE_MESSAGE;
   }
 
-  public static final class InvalidateReplyMessage extends ReplyMessage {
+  public static class InvalidateReplyMessage extends ReplyMessage {
     VersionTag versionTag;
 
     /**

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/ManageBackupBucketMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/ManageBackupBucketMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/ManageBackupBucketMessage.java
index 786006e..170322f 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/ManageBackupBucketMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/ManageBackupBucketMessage.java
@@ -48,7 +48,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
  * @since GemFire 5.0
  *
  */
-public final class ManageBackupBucketMessage extends PartitionMessage {
+public class ManageBackupBucketMessage extends PartitionMessage {
   private static final Logger logger = LogService.getLogger();
 
   /** The key associated with the value that must be sent */
@@ -217,7 +217,7 @@ public final class ManageBackupBucketMessage extends PartitionMessage {
    * 
    * @since GemFire 5.0
    */
-  public static final class ManageBackupBucketReplyMessage extends ReplyMessage {
+  public static class ManageBackupBucketReplyMessage extends ReplyMessage {
 
     protected boolean acceptedBucket;
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/ManageBucketMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/ManageBucketMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/ManageBucketMessage.java
index 1092145..7b91cad 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/ManageBucketMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/ManageBucketMessage.java
@@ -48,7 +48,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
  * @since GemFire 5.0
  *
  */
-public final class ManageBucketMessage extends PartitionMessage {
+public class ManageBucketMessage extends PartitionMessage {
   private static final Logger logger = LogService.getLogger();
 
   /** The key associated with the value that must be sent */
@@ -211,7 +211,7 @@ public final class ManageBucketMessage extends PartitionMessage {
    * 
    * @since GemFire 5.0
    */
-  public static final class ManageBucketReplyMessage extends ReplyMessage {
+  public static class ManageBucketReplyMessage extends ReplyMessage {
 
     protected boolean acceptedBucket;
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/MoveBucketMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/MoveBucketMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/MoveBucketMessage.java
index 8a607c0..6f18013 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/MoveBucketMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/MoveBucketMessage.java
@@ -143,7 +143,7 @@ public class MoveBucketMessage extends PartitionMessage {
     DataSerializer.writeObject(this.source, out);
   }
 
-  public static final class MoveBucketReplyMessage extends ReplyMessage {
+  public static class MoveBucketReplyMessage extends ReplyMessage {
 
     private boolean moved;
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRLoad.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRLoad.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRLoad.java
index a125dbe..1cbad83 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRLoad.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRLoad.java
@@ -27,7 +27,7 @@ import org.apache.geode.DataSerializer;
  * 
  * @since GemFire 6.0
  */
-public final class PRLoad implements DataSerializable {
+public class PRLoad implements DataSerializable {
 
   private static final long serialVersionUID = 778886995284953922L;
   private final float weight;

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRSanityCheckMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRSanityCheckMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRSanityCheckMessage.java
index 5c5af24..e835fce 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRSanityCheckMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRSanityCheckMessage.java
@@ -39,7 +39,7 @@ import java.util.Set;
  * 
  *
  */
-public final class PRSanityCheckMessage extends PartitionMessage {
+public class PRSanityCheckMessage extends PartitionMessage {
 
   private String regionName;
 

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRTombstoneMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRTombstoneMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRTombstoneMessage.java
index 3552b5d..3e734c6 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRTombstoneMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRTombstoneMessage.java
@@ -50,7 +50,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
  * 
  * @since GemFire 7.0
  */
-public final class PRTombstoneMessage extends PartitionMessageWithDirectReply
+public class PRTombstoneMessage extends PartitionMessageWithDirectReply
     implements SerializationVersions {
 
   private static final Logger logger = LogService.getLogger();

http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRUpdateEntryVersionMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRUpdateEntryVersionMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRUpdateEntryVersionMessage.java
index eb7dcaf..b214075 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRUpdateEntryVersionMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PRUpdateEntryVersionMessage.java
@@ -221,7 +221,7 @@ public class PRUpdateEntryVersionMessage extends PartitionMessageWithDirectReply
    * Response for PartitionMessage {@link PRUpdateEntryVersionMessage}.
    * 
    */
-  public static final class UpdateEntryVersionResponse extends PartitionResponse {
+  public static class UpdateEntryVersionResponse extends PartitionResponse {
 
     private volatile boolean versionUpdated;
     private final Object key;


Mime
View raw message