From d8b4b978341d013daaf87636852c6fb80d3a7277 Mon Sep 17 00:00:00 2001 From: John Blum Date: Wed, 24 Sep 2014 14:47:07 -0700 Subject: [PATCH] SGF-330 - Add missing 'disk-synchronous' attribute to the element in the SDG XML namespace (XSD). --- .../data/gemfire/config/spring-gemfire-1.4.xsd | 8 ++++++++ .../data/gemfire/config/spring-gemfire-1.5.xsd | 8 ++++++++ .../data/gemfire/config/spring-gemfire-2.0.xsd | 8 ++++++++ .../config/GemfireV7GatewayNamespaceTest.java | 11 ++++++----- .../gemfire/test/StubGatewaySenderFactory.java | 14 +++++++------- .../data/gemfire/config/gateway-v7-ns.xml | 15 ++++++++++++--- 6 files changed, 49 insertions(+), 15 deletions(-) diff --git a/src/main/resources/org/springframework/data/gemfire/config/spring-gemfire-1.4.xsd b/src/main/resources/org/springframework/data/gemfire/config/spring-gemfire-1.4.xsd index 200e8b6f..4aafb735 100644 --- a/src/main/resources/org/springframework/data/gemfire/config/spring-gemfire-1.4.xsd +++ b/src/main/resources/org/springframework/data/gemfire/config/spring-gemfire-1.4.xsd @@ -2477,6 +2477,14 @@ The maximum time interval that can elapse before a partial batch is sent from a ]]> + + + + + + + + + + + + + + + eventFilters = TestUtils.readField("eventFilters", gatewaySenderFactoryBean); @@ -131,8 +131,8 @@ public class GemfireV7GatewayNamespaceTest extends RecreatingContextTest { assertTrue(transportFilters.get(0) instanceof TestTransportFilter); } - @SuppressWarnings("rawtypes") @Test + @SuppressWarnings("rawtypes") public void testInnerGatewaySender() throws Exception { Region region = ctx.getBean("region-inner-gateway-sender", Region.class); @@ -151,12 +151,13 @@ public class GemfireV7GatewayNamespaceTest extends RecreatingContextTest { assertNotNull(gatewaySender); assertEquals(1, gatewaySender.getRemoteDSId()); assertEquals(false, gatewaySender.isManualStart()); - assertEquals(true,gatewaySender.isRunning()); + assertEquals(true, gatewaySender.isRunning()); assertEquals(10, gatewaySender.getAlertThreshold()); assertEquals(11, gatewaySender.getBatchSize()); assertEquals(3000, gatewaySender.getBatchTimeInterval()); assertEquals(2, gatewaySender.getDispatcherThreads()); assertEquals("diskstore", gatewaySender.getDiskStoreName()); + assertEquals(true, gatewaySender.isDiskSynchronous()); assertTrue(gatewaySender.isBatchConflationEnabled()); assertEquals(50, gatewaySender.getMaximumQueueMemory()); assertEquals(OrderPolicy.THREAD, gatewaySender.getOrderPolicy()); diff --git a/src/test/java/org/springframework/data/gemfire/test/StubGatewaySenderFactory.java b/src/test/java/org/springframework/data/gemfire/test/StubGatewaySenderFactory.java index 609b5fdf..e1c40809 100644 --- a/src/test/java/org/springframework/data/gemfire/test/StubGatewaySenderFactory.java +++ b/src/test/java/org/springframework/data/gemfire/test/StubGatewaySenderFactory.java @@ -88,22 +88,22 @@ public class StubGatewaySenderFactory implements GatewaySenderFactory { when(gatewaySender.getId()).thenReturn(name); when(gatewaySender.getRemoteDSId()).thenReturn(remoteSystemId); when(gatewaySender.getAlertThreshold()).thenReturn(this.alertThreshold); - when(gatewaySender.getBatchSize()).thenReturn(this.batchSize); - when(gatewaySender.getBatchTimeInterval()).thenReturn(this.batchTimeInterval); - when(gatewaySender.getDiskStoreName()).thenReturn(this.diskStoreName); - when(gatewaySender.getDispatcherThreads()).thenReturn(this.dispatcherThreads); when(gatewaySender.getGatewayEventFilters()).thenReturn(this.eventFilters); when(gatewaySender.getGatewayEventSubstitutionFilter()).thenReturn(gatewayEventSubstitutionFilter); when(gatewaySender.getGatewayTransportFilters()).thenReturn(this.transportFilters); - when(gatewaySender.getMaximumQueueMemory()).thenReturn(this.maxQueueMemory); - when(gatewaySender.getOrderPolicy()).thenReturn(this.orderPolicy); + when(gatewaySender.isManualStart()).thenReturn(this.manualStart); when(gatewaySender.getSocketBufferSize()).thenReturn(this.socketBufferSize); when(gatewaySender.getSocketReadTimeout()).thenReturn(this.socketReadTimeout); - when(gatewaySender.isManualStart()).thenReturn(this.manualStart); when(gatewaySender.isBatchConflationEnabled()).thenReturn(this.batchConflationEnabled); + when(gatewaySender.getBatchSize()).thenReturn(this.batchSize); + when(gatewaySender.getBatchTimeInterval()).thenReturn(this.batchTimeInterval); + when(gatewaySender.getDiskStoreName()).thenReturn(this.diskStoreName); when(gatewaySender.isDiskSynchronous()).thenReturn(this.diskSynchronous); + when(gatewaySender.getDispatcherThreads()).thenReturn(this.dispatcherThreads); + when(gatewaySender.getMaximumQueueMemory()).thenReturn(this.maxQueueMemory); when(gatewaySender.isParallel()).thenReturn(this.parallel); when(gatewaySender.isPersistenceEnabled()).thenReturn(this.persistenceEnabled); + when(gatewaySender.getOrderPolicy()).thenReturn(this.orderPolicy); when(gatewaySender.isRunning()).thenAnswer(new Answer() { @Override public Boolean answer(InvocationOnMock invocation) throws Throwable { diff --git a/src/test/resources/org/springframework/data/gemfire/config/gateway-v7-ns.xml b/src/test/resources/org/springframework/data/gemfire/config/gateway-v7-ns.xml index 3ed666f1..45200a85 100644 --- a/src/test/resources/org/springframework/data/gemfire/config/gateway-v7-ns.xml +++ b/src/test/resources/org/springframework/data/gemfire/config/gateway-v7-ns.xml @@ -1,13 +1,21 @@ + http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd +" default-lazy-init="true"> - + + GemfireV7GatewayNamespaceTest + 0 + config + + + + dispatcher-threads="12" disk-synchronous="false" manual-start="true">