diff --git a/src/main/java/org/springframework/data/gemfire/PeerRegionFactoryBean.java b/src/main/java/org/springframework/data/gemfire/PeerRegionFactoryBean.java index 50aa88dd..139b893a 100644 --- a/src/main/java/org/springframework/data/gemfire/PeerRegionFactoryBean.java +++ b/src/main/java/org/springframework/data/gemfire/PeerRegionFactoryBean.java @@ -752,19 +752,6 @@ public abstract class PeerRegionFactoryBean extends ConfigurableRegionFact this.dataPolicy = dataPolicy; } - /** - * Configures the {@link DataPolicy} for this {@link Region} as a {@link String}. - * - * @param dataPolicyName {@link String} containing the name of the {@link DataPolicy}, - * (e.g. {@literal PARTITION} or {@literal REPLICATE}, etc). - * @see #setDataPolicy(org.apache.geode.cache.DataPolicy) - * @deprecated as of 1.4.0; use setDataPolicy(:DataPolicy) instead. - */ - @Deprecated - public void setDataPolicy(String dataPolicyName) { - setDataPolicy(new DataPolicyConverter().convert(dataPolicyName)); - } - /** * Returns resolved {@link DataPolicy} as configured with the {@link RegionFactory} * when creating this {@link Region}. diff --git a/src/main/java/org/springframework/data/gemfire/SubscriptionAttributesFactoryBean.java b/src/main/java/org/springframework/data/gemfire/SubscriptionAttributesFactoryBean.java index 3ae25b33..ba1e3900 100644 --- a/src/main/java/org/springframework/data/gemfire/SubscriptionAttributesFactoryBean.java +++ b/src/main/java/org/springframework/data/gemfire/SubscriptionAttributesFactoryBean.java @@ -45,7 +45,7 @@ public class SubscriptionAttributesFactoryBean implements FactoryBean getObjectType() { - return (subscriptionAttributes != null ? subscriptionAttributes.getClass() : SubscriptionAttributes.class); + + return this.subscriptionAttributes != null + ? this.subscriptionAttributes.getClass() + : SubscriptionAttributes.class; } /* @@ -83,7 +86,7 @@ public class SubscriptionAttributesFactoryBean implements FactoryBean extends ConfigurableRegionFactoryBean this.dataPolicy = dataPolicy; } - /** - * An alternate way to set the Data Policy, using the String name of the enumerated value. - * - * @param dataPolicyName the enumerated value String name of the Data Policy. - * @see org.apache.geode.cache.DataPolicy - * @see #setDataPolicy(org.apache.geode.cache.DataPolicy) - * @deprecated use setDataPolicy(:DataPolicy) instead. - */ - @Deprecated - public void setDataPolicyName(String dataPolicyName) { - DataPolicy resolvedDataPolicy = new DataPolicyConverter().convert(dataPolicyName); - Assert.notNull(resolvedDataPolicy, String.format("Data Policy [%1$s] is not valid", dataPolicyName)); - setDataPolicy(resolvedDataPolicy); - } - final boolean isDestroy() { return this.destroy; } diff --git a/src/main/java/org/springframework/data/gemfire/client/Interest.java b/src/main/java/org/springframework/data/gemfire/client/Interest.java index f8ee0f4a..1d873885 100644 --- a/src/main/java/org/springframework/data/gemfire/client/Interest.java +++ b/src/main/java/org/springframework/data/gemfire/client/Interest.java @@ -129,33 +129,6 @@ public class Interest implements InitializingBean { afterPropertiesSet(); } - /** - * @deprecated - * @see #Interest(Object, InterestResultPolicy) - */ - @Deprecated - public Interest(K key, String policy) { - this(key, policy, DEFAULT_DURABLE, DEFAULT_RECEIVE_VALUES); - } - - /** - * @deprecated - * @see #Interest(Object, InterestResultPolicy, boolean) - */ - @Deprecated - public Interest(K key, String policy, boolean durable) { - this(key, policy, durable, DEFAULT_RECEIVE_VALUES); - } - - /** - * @deprecated - * @see #Interest(Object, InterestResultPolicy, boolean, boolean) - */ - @Deprecated - public Interest(K key, String policy, boolean durable, boolean receiveValues) { - this(key, (InterestResultPolicy) constants.asObject(policy), durable, receiveValues); - } - /** * @inheritDoc */ diff --git a/src/main/java/org/springframework/data/gemfire/function/GemfireFunctionUtils.java b/src/main/java/org/springframework/data/gemfire/function/GemfireFunctionUtils.java index df89f9e1..9d08489e 100644 --- a/src/main/java/org/springframework/data/gemfire/function/GemfireFunctionUtils.java +++ b/src/main/java/org/springframework/data/gemfire/function/GemfireFunctionUtils.java @@ -22,7 +22,6 @@ import java.lang.reflect.AnnotatedElement; import java.lang.reflect.Method; import java.util.Arrays; import java.util.List; -import java.util.Map; import java.util.Optional; import java.util.stream.Collectors; @@ -195,23 +194,6 @@ public abstract class GemfireFunctionUtils { } - /** - * Wrap the {@link Object target object} and {@link Method method} in a Pivotal GemFire/Apache Geode {@link Function} - * and register the {@link Function} with the {@link FunctionService}. - * - * @param target {@link Object target object}. - * @param method {@link Method} bound to a {@link Function}. - * @param gemfireFunctionAttributes {@link GemfireFunction} annotation {@link Map attributes}. - * @param overwrite if {@literal true}, will replace any existing {@link Function} having the same ID. - * @deprecated use {@link #registerFunctionForPojoMethod(Object, Method, AnnotationAttributes, boolean)} instead. - */ - @Deprecated - public static void registerFunctionForPojoMethod(Object target, Method method, - Map gemfireFunctionAttributes, boolean overwrite) { - - registerFunctionForPojoMethod(target, method, AnnotationAttributes.fromMap(gemfireFunctionAttributes), overwrite); - } - /** * Wrap the {@link Object target object} and {@link Method method} in a Pivotal GemFire/Apache Geode {@link Function} * and register the {@link Function} with the {@link FunctionService}. diff --git a/src/main/java/org/springframework/data/gemfire/mapping/MappingPdxSerializer.java b/src/main/java/org/springframework/data/gemfire/mapping/MappingPdxSerializer.java index e02113b0..3aab83e4 100644 --- a/src/main/java/org/springframework/data/gemfire/mapping/MappingPdxSerializer.java +++ b/src/main/java/org/springframework/data/gemfire/mapping/MappingPdxSerializer.java @@ -294,14 +294,6 @@ public class MappingPdxSerializer implements PdxSerializer, ApplicationContextAw Optional.ofNullable(customPdxSerializers).ifPresent(this.customPdxSerializers::putAll); } - /** - * @deprecated please use ({@link #setCustomPdxSerializers(Map)} instead. - */ - @Deprecated - public void setCustomSerializers(Map, PdxSerializer> customSerializers) { - setCustomPdxSerializers(customSerializers); - } - /** * Returns a {@link Map mapping} of application {@link Class domain types} to custom * {@link PdxSerializer PDX serializers} used to customize the serialization @@ -317,15 +309,6 @@ public class MappingPdxSerializer implements PdxSerializer, ApplicationContextAw return Collections.unmodifiableMap(this.customPdxSerializers); } - /** - * @deprecated please use {@link #getCustomPdxSerializers()} instead. - */ - @Deprecated - @SuppressWarnings("unchecked") - protected Map, PdxSerializer> getCustomSerializers() { - return (Map, PdxSerializer>) getCustomPdxSerializers(); - } - /** * Returns a custom PDX serializer for the given {@link PersistentProperty entity persistent property}. * @@ -346,15 +329,6 @@ public class MappingPdxSerializer implements PdxSerializer, ApplicationContextAw .orElse(null); } - /** - * @deprecated please use {@link #getCustomPdxSerializer(PersistentProperty)} instead. - */ - @Nullable - @Deprecated - protected PdxSerializer getCustomSerializer(Class type) { - return getCustomPdxSerializers().get(type); - } - /** * Configures the {@link EntityInstantiator EntityInstantiators} used to create the instances * read by this {@link PdxSerializer}. diff --git a/src/main/java/org/springframework/data/gemfire/wan/GatewaySenderFactoryBean.java b/src/main/java/org/springframework/data/gemfire/wan/GatewaySenderFactoryBean.java index df435521..b97074e6 100644 --- a/src/main/java/org/springframework/data/gemfire/wan/GatewaySenderFactoryBean.java +++ b/src/main/java/org/springframework/data/gemfire/wan/GatewaySenderFactoryBean.java @@ -88,8 +88,9 @@ public class GatewaySenderFactoryBean extends AbstractWANComponentFactoryBean extends PeerRegionFactoryBean { - } + protected static class TestRegionFactoryBean extends PeerRegionFactoryBean { } + } diff --git a/src/test/java/org/springframework/data/gemfire/client/ClientRegionFactoryBeanTest.java b/src/test/java/org/springframework/data/gemfire/client/ClientRegionFactoryBeanTest.java index 469ae89f..b343aae4 100644 --- a/src/test/java/org/springframework/data/gemfire/client/ClientRegionFactoryBeanTest.java +++ b/src/test/java/org/springframework/data/gemfire/client/ClientRegionFactoryBeanTest.java @@ -465,34 +465,6 @@ public class ClientRegionFactoryBeanTest { verify(mockRegionAttributes, times(1)).getPoolName(); } - @Test - @SuppressWarnings("deprecation") - public void setDataPolicyName() throws Exception { - - factoryBean.setDataPolicyName("NORMAL"); - - assertEquals(DataPolicy.NORMAL, TestUtils.readField("dataPolicy", factoryBean)); - } - - @Test(expected = IllegalArgumentException.class) - @SuppressWarnings("deprecation") - public void setDataPolicyNameWithInvalidName() throws Exception { - - try { - factoryBean.setDataPolicyName("INVALID"); - } - catch (IllegalArgumentException expected) { - - assertThat(expected).hasMessage("Data Policy [INVALID] is not valid"); - assertThat(expected).hasNoCause(); - - throw expected; - } - finally { - assertNull(TestUtils.readField("dataPolicy", factoryBean)); - } - } - @Test public void isPersistentIsCorrect() { diff --git a/src/test/java/org/springframework/data/gemfire/client/InterestUnitTests.java b/src/test/java/org/springframework/data/gemfire/client/InterestUnitTests.java index e764c4fd..34f16996 100644 --- a/src/test/java/org/springframework/data/gemfire/client/InterestUnitTests.java +++ b/src/test/java/org/springframework/data/gemfire/client/InterestUnitTests.java @@ -129,22 +129,6 @@ public class InterestUnitTests { new Interest<>(null); } - @Test - @SuppressWarnings("deprecation") - public void constructInterestWithStringPolicy() { - Interest interest = new Interest<>("mockKey", "nOnE"); - - assertThat(interest.getKey()).isEqualTo("mockKey"); - assertThat(interest.getPolicy()).isEqualTo(InterestResultPolicy.NONE); - assertThat(interest.getType()).isEqualTo(KEY); - } - - @Test(expected = IllegalArgumentException.class) - @SuppressWarnings("deprecation") - public void constructInterestWithInvalidStringPolicy() { - new Interest<>("testKey", "INVALID"); - } - @Test public void isAlphanumericWhitespace() { Interest interest = newInterest("key"); diff --git a/src/test/java/org/springframework/data/gemfire/mapping/MappingPdxSerializerUnitTests.java b/src/test/java/org/springframework/data/gemfire/mapping/MappingPdxSerializerUnitTests.java index f86fd083..d892acbc 100644 --- a/src/test/java/org/springframework/data/gemfire/mapping/MappingPdxSerializerUnitTests.java +++ b/src/test/java/org/springframework/data/gemfire/mapping/MappingPdxSerializerUnitTests.java @@ -321,26 +321,6 @@ public class MappingPdxSerializerUnitTests { assertThat(this.pdxSerializer.getCustomPdxSerializer(addressProperty)).isEqualTo(mockTypedSerializer); } - @Test - // TODO remove! - @SuppressWarnings("deprecation") - public void getCustomSerializerForMappedTypeReturnsPdxSerializer() { - - PdxSerializer mockPdxSerializer = mock(PdxSerializer.class); - - this.pdxSerializer.setCustomPdxSerializers(Collections.singletonMap(Person.class, mockPdxSerializer)); - - assertThat(this.pdxSerializer.getCustomSerializer(Person.class)).isEqualTo(mockPdxSerializer); - } - - @Test - // TODO remove! - @SuppressWarnings("deprecation") - public void getCustomSerializerForUnmappedTypeReturnsNull() { - assertThat(this.pdxSerializer.getCustomPdxSerializers()).isEmpty(); - assertThat(this.pdxSerializer.getCustomSerializer(Address.class)).isNull(); - } - @Test public void toFullyQualifiedPropertyName() { diff --git a/src/test/java/org/springframework/data/gemfire/wan/GatewaySenderFactoryBeanTest.java b/src/test/java/org/springframework/data/gemfire/wan/GatewaySenderFactoryBeanTest.java index 6ece8d48..366c3105 100644 --- a/src/test/java/org/springframework/data/gemfire/wan/GatewaySenderFactoryBeanTest.java +++ b/src/test/java/org/springframework/data/gemfire/wan/GatewaySenderFactoryBeanTest.java @@ -46,13 +46,13 @@ import org.springframework.data.gemfire.TestUtils; */ public class GatewaySenderFactoryBeanTest { - protected Cache createMockCacheWithGatewayInfrastructure(final GatewaySenderFactory gatewaySenderFactory) { + private Cache mockCacheWithGatewayInfrastructure(final GatewaySenderFactory gatewaySenderFactory) { Cache mockCache = mock(Cache.class); when(mockCache.createGatewaySenderFactory()).thenReturn(gatewaySenderFactory); return mockCache; } - protected GatewaySenderFactory createMockGatewaySenderFactory(final String gatewaySenderName, + private GatewaySenderFactory mockGatewaySenderFactory(final String gatewaySenderName, final int remoteDistributedSystemId) { GatewaySenderFactory mockGatewaySenderFactory = mock(GatewaySenderFactory.class); GatewaySender mockGatewaySender = mock(GatewaySender.class); @@ -107,11 +107,13 @@ public class GatewaySenderFactoryBeanTest { } @Test - public void testConcurrentParallelGatewaySender() throws Exception { - GatewaySenderFactory mockGatewaySenderFactory = createMockGatewaySenderFactory("g0", 69); + public void concurrentParallelGatewaySenderCreation() throws Exception { + + GatewaySenderFactory mockGatewaySenderFactory = + mockGatewaySenderFactory("g0", 69); GatewaySenderFactoryBean factoryBean = new GatewaySenderFactoryBean( - createMockCacheWithGatewayInfrastructure(mockGatewaySenderFactory)); + mockCacheWithGatewayInfrastructure(mockGatewaySenderFactory)); factoryBean.setName("g0"); factoryBean.setRemoteDistributedSystemId(69); @@ -129,53 +131,13 @@ public class GatewaySenderFactoryBeanTest { } @Test - public void testParallelGatewaySender() throws Exception { - GatewaySenderFactory mockGatewaySenderFactory = createMockGatewaySenderFactory("g1", 69); + public void concurrentSerialGatewaySenderCreation() throws Exception { + + GatewaySenderFactory mockGatewaySenderFactory = + mockGatewaySenderFactory("g4", 21); GatewaySenderFactoryBean factoryBean = new GatewaySenderFactoryBean( - createMockCacheWithGatewayInfrastructure(mockGatewaySenderFactory)); - - factoryBean.setName("g1"); - factoryBean.setRemoteDistributedSystemId(69); - factoryBean.setParallel(true); - factoryBean.doInit(); - - verifyExpectations(factoryBean, mockGatewaySenderFactory); - - GatewaySender gatewaySender = factoryBean.getObject(); - - assertNotNull(gatewaySender); - assertEquals("g1", gatewaySender.getId()); - assertEquals(69, gatewaySender.getRemoteDSId()); - } - - @Test(expected = IllegalArgumentException.class) - public void testParallelGatewaySenderWithOrderPolicy() { - GatewaySenderFactory mockGatewaySenderFactory = createMockGatewaySenderFactory("g2", 69); - - GatewaySenderFactoryBean factoryBean = new GatewaySenderFactoryBean( - createMockCacheWithGatewayInfrastructure(mockGatewaySenderFactory)); - - factoryBean.setName("g2"); - factoryBean.setRemoteDistributedSystemId(69); - factoryBean.setParallel(true); - factoryBean.setOrderPolicy("KEY"); - - try { - factoryBean.doInit(); - } - catch (IllegalArgumentException expected) { - assertEquals("OrderPolicy cannot be used with a Parallel GatewaySender", expected.getMessage()); - throw expected; - } - } - - @Test - public void testConcurrentSerialGatewaySender() throws Exception { - GatewaySenderFactory mockGatewaySenderFactory = createMockGatewaySenderFactory("g4", 21); - - GatewaySenderFactoryBean factoryBean = new GatewaySenderFactoryBean( - createMockCacheWithGatewayInfrastructure(mockGatewaySenderFactory)); + mockCacheWithGatewayInfrastructure(mockGatewaySenderFactory)); factoryBean.setName("g4"); factoryBean.setRemoteDistributedSystemId(21); @@ -193,17 +155,63 @@ public class GatewaySenderFactoryBeanTest { } @Test - public void testGatewaySenderWithOrderPolicyAndDispatcherThreads() throws Exception { + public void parallelGatewaySenderCreation() throws Exception { GatewaySenderFactory mockGatewaySenderFactory = - createMockGatewaySenderFactory("g5", 42); + mockGatewaySenderFactory("g1", 69); GatewaySenderFactoryBean factoryBean = new GatewaySenderFactoryBean( - createMockCacheWithGatewayInfrastructure(mockGatewaySenderFactory)); + mockCacheWithGatewayInfrastructure(mockGatewaySenderFactory)); - factoryBean.setName("g5"); - factoryBean.setRemoteDistributedSystemId(42); - factoryBean.setOrderPolicy("THREAD"); + factoryBean.setName("g1"); + factoryBean.setRemoteDistributedSystemId(69); + factoryBean.setParallel(true); + factoryBean.doInit(); + + verifyExpectations(factoryBean, mockGatewaySenderFactory); + + GatewaySender gatewaySender = factoryBean.getObject(); + + assertNotNull(gatewaySender); + assertEquals("g1", gatewaySender.getId()); + assertEquals(69, gatewaySender.getRemoteDSId()); + } + + @Test(expected = IllegalArgumentException.class) + public void parallelGatewaySenderWithOrderPolicyCreation() { + + GatewaySenderFactory mockGatewaySenderFactory = + mockGatewaySenderFactory("g2", 69); + + GatewaySenderFactoryBean factoryBean = new GatewaySenderFactoryBean( + mockCacheWithGatewayInfrastructure(mockGatewaySenderFactory)); + + factoryBean.setName("g2"); + factoryBean.setRemoteDistributedSystemId(69); + factoryBean.setParallel(true); + factoryBean.setOrderPolicy(GatewaySender.OrderPolicy.KEY); + + try { + factoryBean.doInit(); + } + catch (IllegalArgumentException expected) { + assertEquals("OrderPolicy cannot be used with a Parallel GatewaySender", expected.getMessage()); + throw expected; + } + } + + @Test + public void gatewaySenderCreationWithDiskSynchronousAndNoPersistence() throws Exception { + + GatewaySenderFactory mockGatewaySenderFactory = + mockGatewaySenderFactory("g7", 51); + + GatewaySenderFactoryBean factoryBean = new GatewaySenderFactoryBean( + mockCacheWithGatewayInfrastructure(mockGatewaySenderFactory)); + + factoryBean.setName("g4"); + factoryBean.setRemoteDistributedSystemId(21); + factoryBean.setParallel(false); factoryBean.setDispatcherThreads(1); factoryBean.doInit(); @@ -212,16 +220,18 @@ public class GatewaySenderFactoryBeanTest { GatewaySender gatewaySender = factoryBean.getObject(); assertNotNull(gatewaySender); - assertEquals("g5", gatewaySender.getId()); - assertEquals(42, gatewaySender.getRemoteDSId()); + assertEquals("g4", gatewaySender.getId()); + assertEquals(21, gatewaySender.getRemoteDSId()); } @Test - public void testGatewaySenderWithOverflowDiskStoreNoPersistence() throws Exception { - GatewaySenderFactory mockGatewaySenderFactory = createMockGatewaySenderFactory("g6", 51); + public void gatewaySenderCreationWithOverflowDiskStoreAndNoPersistence() throws Exception { + + GatewaySenderFactory mockGatewaySenderFactory = + mockGatewaySenderFactory("g6", 51); GatewaySenderFactoryBean factoryBean = new GatewaySenderFactoryBean( - createMockCacheWithGatewayInfrastructure(mockGatewaySenderFactory)); + mockCacheWithGatewayInfrastructure(mockGatewaySenderFactory)); factoryBean.setName("g6"); factoryBean.setRemoteDistributedSystemId(51); @@ -239,11 +249,13 @@ public class GatewaySenderFactoryBeanTest { } @Test - public void testGatewaySenderWithDiskSynchronousSetPersistenceUnset() throws Exception { - GatewaySenderFactory mockGatewaySenderFactory = createMockGatewaySenderFactory("g7", 51); + public void gatewaySenderCreationWithOrderPolicyAndDispatcherThreads() throws Exception { + + GatewaySenderFactory mockGatewaySenderFactory = + mockGatewaySenderFactory("g5", 42); GatewaySenderFactoryBean factoryBean = new GatewaySenderFactoryBean( - createMockCacheWithGatewayInfrastructure(mockGatewaySenderFactory)); + mockCacheWithGatewayInfrastructure(mockGatewaySenderFactory)); factoryBean.setName("g7"); factoryBean.setRemoteDistributedSystemId(51); @@ -255,7 +267,7 @@ public class GatewaySenderFactoryBeanTest { GatewaySender gatewaySender = factoryBean.getObject(); assertNotNull(gatewaySender); - assertEquals("g7", gatewaySender.getId()); - assertEquals(51, gatewaySender.getRemoteDSId()); + assertEquals("g5", gatewaySender.getId()); + assertEquals(42, gatewaySender.getRemoteDSId()); } }