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">