[geode] branch develop updated: GEODE-3649 TypeRegistry stays open after Cache is closed

[bs...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

bschuchardt pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/develop by this push:
     new eae85e8  GEODE-3649 TypeRegistry stays open after Cache is closed
eae85e8 is described below

commit eae85e80fcc4201e6228df0a0775143bb57e70e7
Author: Bruce Schuchardt <bs...@pivotal.io>
AuthorDate: Mon Feb 4 10:09:33 2019 -0800

    GEODE-3649 TypeRegistry stays open after Cache is closed
    
    Initialize the PDX registry before attempting an auto-
    reconnect.
---
 .../apache/geode/distributed/internal/InternalDistributedSystem.java   | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/InternalDistributedSystem.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/InternalDistributedSystem.java
index 00d6851..c253160 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/InternalDistributedSystem.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/InternalDistributedSystem.java
@@ -115,6 +115,7 @@ import org.apache.geode.internal.statistics.StatisticsRegistry;
 import org.apache.geode.internal.statistics.platform.LinuxProcFsStatistics;
 import org.apache.geode.internal.tcp.ConnectionTable;
 import org.apache.geode.management.ManagementException;
+import org.apache.geode.pdx.internal.TypeRegistry;
 import org.apache.geode.security.GemFireSecurityException;
 import org.apache.geode.security.PostProcessor;
 import org.apache.geode.security.SecurityManager;
@@ -2652,6 +2653,8 @@ public class InternalDistributedSystem extends DistributedSystem
           logger.warn("Exception disconnecting for reconnect", ee);
         }
 
+        TypeRegistry.init();
+
         try {
           reconnectLock.wait(timeOut);
         } catch (InterruptedException e) {