From 50827c21cb1e962e2eb46d5b311e6c63a15a3980 Mon Sep 17 00:00:00 2001 From: John Blum Date: Wed, 5 Dec 2018 10:23:37 -0800 Subject: [PATCH] Simplify Spring Session DataSerializer (Spy) re-registration logic. --- ...entCachingProxyRegionIntegrationTests.java | 22 +++---------------- 1 file changed, 3 insertions(+), 19 deletions(-) diff --git a/spring-session-data-geode/src/integration-test/java/org/springframework/session/data/gemfire/ConcurrentSessionOperationsUsingClientCachingProxyRegionIntegrationTests.java b/spring-session-data-geode/src/integration-test/java/org/springframework/session/data/gemfire/ConcurrentSessionOperationsUsingClientCachingProxyRegionIntegrationTests.java index 0898065..8b622bb 100644 --- a/spring-session-data-geode/src/integration-test/java/org/springframework/session/data/gemfire/ConcurrentSessionOperationsUsingClientCachingProxyRegionIntegrationTests.java +++ b/spring-session-data-geode/src/integration-test/java/org/springframework/session/data/gemfire/ConcurrentSessionOperationsUsingClientCachingProxyRegionIntegrationTests.java @@ -26,7 +26,6 @@ import static org.springframework.session.data.gemfire.AbstractGemFireOperations import java.io.DataOutput; import java.io.IOException; -import java.lang.reflect.Method; import java.util.Arrays; import java.util.Objects; import java.util.concurrent.atomic.AtomicReference; @@ -189,25 +188,10 @@ public class ConcurrentSessionOperationsUsingClientCachingProxyRegionIntegration private DataSerializer reregisterDataSerializer(DataSerializer dataSerializer) { - try { + InternalDataSerializer.unregister(dataSerializer.getId()); + InternalDataSerializer._register(dataSerializer, false); - if (dataSerializer != null) { - - InternalDataSerializer.unregister(dataSerializer.getId()); - - Method registerDataSerializer = InternalDataSerializer.class - .getDeclaredMethod("_register", DataSerializer.class, Boolean.TYPE); - - registerDataSerializer.setAccessible(true); - - registerDataSerializer.invoke(null, dataSerializer, false); - } - - return dataSerializer; - } - catch (Exception cause) { - throw new RuntimeException(cause); - } + return dataSerializer; } private Session get(String id) {