diff --git a/.springBeans b/.springBeans deleted file mode 100644 index d3321de6..00000000 --- a/.springBeans +++ /dev/null @@ -1,14 +0,0 @@ - - - 1 - - - - - - - src/test/resources/org/springframework/data/gemfire/support/GemfirePersistenceExceptionTranslationTest-context.xml - - - - diff --git a/build.gradle b/build.gradle index c229a625..41be5fb1 100644 --- a/build.gradle +++ b/build.gradle @@ -14,8 +14,6 @@ group = 'org.springframework.data' repositories { maven { url "http://repo.springsource.org/libs-snapshot" } maven { url "http://repo.springsource.org/plugins-release"} - //TODO: This is temporary for the Gemfire 7.0 dependency - maven { url "https://repo.springsource.org/ext-private-local"} } diff --git a/docs/src/reference/docbook/introduction/introduction.xml b/docs/src/reference/docbook/introduction/introduction.xml index 8bec52b3..5e565b39 100644 --- a/docs/src/reference/docbook/introduction/introduction.xml +++ b/docs/src/reference/docbook/introduction/introduction.xml @@ -1,8 +1,20 @@ + + + Introduction - - This document is the reference guide for Spring Data GemFire project (SGF). It explains the relationship - between Spring framework and vFabric GemFire - and defines the basic concepts, semantics, and effect use of Spring's support for GemFire. + +
+ This reference guide for the Spring Data GemFire project (SGF) + explains how to use Spring framework to configure and develop + applications with vFabric GemFire. It presents the basic concepts, + semantics and provides numerous examples to help you get started. - \ No newline at end of file + + Spring Data GemFire started as a top level Spring project called + Spring GemFire and has sinced moved under the Spring Data umbrella + project and has been renamed accordingly. +
+ + diff --git a/docs/src/reference/docbook/links.xml b/docs/src/reference/docbook/links.xml index 178170d3..2e4cb562 100644 --- a/docs/src/reference/docbook/links.xml +++ b/docs/src/reference/docbook/links.xml @@ -1,12 +1,23 @@ - - Useful Links + + Useful Links - + + + Spring Data GemFire Home Page + - Spring GemFire Integration Home Page - here - SpringSource blog - here - GemFire Community - here - - - \ No newline at end of file + + SpringSource Blog + + + + New para + + + diff --git a/docs/src/reference/docbook/reference/introduction.xml b/docs/src/reference/docbook/reference/introduction.xml index 6e5eb127..09a2a068 100644 --- a/docs/src/reference/docbook/reference/introduction.xml +++ b/docs/src/reference/docbook/reference/introduction.xml @@ -1,32 +1,39 @@ - - Document structure + + + + Reference Guide - The following chapters explain the core functionality offered by Spring Data GemFire. + + Document structure - describes the configuration support provided for - bootstrapping, initializing, configuring, and accessing GemFire caches, regions and distributed system components. + The following chapters explain the core functionality offered by + Spring Data GemFire. - explains the integration between the GemFire APIs and - the various data access features available in Spring, such as transaction management - and exception translation. - + describes the configuration support + provided for bootstrapping, initializing, configuring, and accessing + GemFire caches, regions and distributed system components. - describes the enhancements for GemFire - (de)serialization and management of associated objects. - - - describes persistence mapping for POJOs stored in GemFire using Spring Data - - - describes how to create and use GemFire Repositories using Spring Data - + explains the integration between the GemFire + APIs and the various data access features available in Spring, such as + transaction management and exception translation. - describes the samples provided with the distribution - to illustrate the various features available in Spring GemFire. - + describes the enhancements for + GemFire (de)serialization and management of associated objects. - - \ No newline at end of file + + diff --git a/gradle.properties b/gradle.properties index 28e0a6af..b9617eba 100644 --- a/gradle.properties +++ b/gradle.properties @@ -7,8 +7,7 @@ slf4jVersion = 1.6.4 # Common libraries springVersion = 3.1.2.RELEASE springDataCommonsVersion = 1.4.0.M1 -#Temporary until release of 7.0 -gemfireVersion = 7.0.Beta-SNAPSHOT +gemfireVersion = 6.6.3 gemfireVersion6x = 6.6.3 # Testing diff --git a/src/main/java/org/springframework/data/gemfire/config/AsyncEventQueueParser.java b/src/main/java/org/springframework/data/gemfire/config/AsyncEventQueueParser.java deleted file mode 100644 index ef7d697c..00000000 --- a/src/main/java/org/springframework/data/gemfire/config/AsyncEventQueueParser.java +++ /dev/null @@ -1,54 +0,0 @@ -/* - * Copyright 2010-2012 the original author or authors. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.springframework.data.gemfire.config; - -import org.springframework.beans.factory.support.BeanDefinitionBuilder; -import org.springframework.beans.factory.xml.AbstractSingleBeanDefinitionParser; -import org.springframework.beans.factory.xml.ParserContext; -import org.springframework.data.gemfire.wan.AsyncEventQueueFactoryBean; -import org.springframework.util.xml.DomUtils; -import org.w3c.dom.Element; - -import com.gemstone.gemfire.internal.lang.StringUtils; - -/** - * @author David Turanski - * - */ -public class AsyncEventQueueParser extends AbstractSingleBeanDefinitionParser { - - @Override - protected Class getBeanClass(Element element) { - return AsyncEventQueueFactoryBean.class; - } - - @Override - protected void doParse(Element element, ParserContext parserContext, BeanDefinitionBuilder builder) { - builder.setLazyInit(false); - Element asyncEventListenerElement = DomUtils.getChildElementByTagName(element, "async-event-listener"); - Object asyncEventListener = ParsingUtils.parseRefOrSingleNestedBeanDeclaration(parserContext, - asyncEventListenerElement, builder); - String cacheName = StringUtils.isEmpty(element.getAttribute("cache-ref")) ? "gemfireCache" : element - .getAttribute("cache-ref"); - builder.addConstructorArgReference(cacheName); - builder.addConstructorArgValue(asyncEventListener); - ParsingUtils.setPropertyValue(element, builder, "batch-size"); - ParsingUtils.setPropertyValue(element, builder, "maximum-queue-memory"); - ParsingUtils.setPropertyValue(element, builder, "disk-store-ref"); - ParsingUtils.setPropertyValue(element, builder, "persistent"); - ParsingUtils.setPropertyValue(element, builder, "parallel"); - } -} diff --git a/src/main/java/org/springframework/data/gemfire/config/GatewayReceiverParser.java b/src/main/java/org/springframework/data/gemfire/config/GatewayReceiverParser.java deleted file mode 100644 index 58a10827..00000000 --- a/src/main/java/org/springframework/data/gemfire/config/GatewayReceiverParser.java +++ /dev/null @@ -1,48 +0,0 @@ -/* - * Copyright 2010-2012 the original author or authors. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.springframework.data.gemfire.config; - -import org.springframework.beans.factory.support.BeanDefinitionBuilder; -import org.springframework.beans.factory.xml.AbstractSimpleBeanDefinitionParser; -import org.springframework.beans.factory.xml.ParserContext; -import org.springframework.data.gemfire.wan.GatewayReceiverFactoryBean; -import org.springframework.util.StringUtils; -import org.w3c.dom.Element; - -/** - * @author David Turanski - * - */ -class GatewayReceiverParser extends AbstractSimpleBeanDefinitionParser { - @Override - protected Class getBeanClass(Element element) { - return GatewayReceiverFactoryBean.class; - } - - @Override - protected void doParse(Element element, ParserContext parserContext, BeanDefinitionBuilder builder) { - builder.setLazyInit(false); - String cacheRef = element.getAttribute("cache-ref"); - // add cache reference (fallback to default if nothing is specified) - builder.addConstructorArgReference((StringUtils.hasText(cacheRef) ? cacheRef : "gemfireCache")); - ParsingUtils.setPropertyValue(element, builder, "start-port"); - ParsingUtils.setPropertyValue(element, builder, "end-port"); - ParsingUtils.setPropertyValue(element, builder, "socket-buffer-size"); - ParsingUtils.setPropertyValue(element, builder, "maximum-time-between-pings"); - ParsingUtils.setPropertyValue(element, builder, "bind-address"); - ParsingUtils.parseTransportFilters(element, parserContext, builder); - } -} diff --git a/src/main/java/org/springframework/data/gemfire/config/GatewaySenderParser.java b/src/main/java/org/springframework/data/gemfire/config/GatewaySenderParser.java deleted file mode 100644 index a42392b0..00000000 --- a/src/main/java/org/springframework/data/gemfire/config/GatewaySenderParser.java +++ /dev/null @@ -1,67 +0,0 @@ -/* - * Copyright 2010-2012 the original author or authors. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.springframework.data.gemfire.config; - -import org.springframework.beans.factory.support.BeanDefinitionBuilder; -import org.springframework.beans.factory.xml.AbstractSimpleBeanDefinitionParser; -import org.springframework.beans.factory.xml.ParserContext; -import org.springframework.data.gemfire.wan.GatewaySenderFactoryBean; -import org.springframework.util.StringUtils; -import org.springframework.util.xml.DomUtils; -import org.w3c.dom.Element; - -/** - * @author David Turanski - * - */ -class GatewaySenderParser extends AbstractSimpleBeanDefinitionParser { - - @Override - protected Class getBeanClass(Element element) { - return GatewaySenderFactoryBean.class; - } - - @Override - protected void doParse(Element element, ParserContext parserContext, BeanDefinitionBuilder builder) { - builder.setLazyInit(false); - String cacheRef = element.getAttribute("cache-ref"); - // add cache reference (fallback to default if nothing is specified) - builder.addConstructorArgReference((StringUtils.hasText(cacheRef) ? cacheRef : "gemfireCache")); - ParsingUtils.setPropertyValue(element, builder, "alert-threshold"); - ParsingUtils.setPropertyValue(element, builder, "batch-size"); - ParsingUtils.setPropertyValue(element, builder, "batch-time-interval"); - ParsingUtils.setPropertyValue(element, builder, "disk-store-ref"); - ParsingUtils.setPropertyValue(element, builder, "disk-synchronous"); - ParsingUtils.setPropertyValue(element, builder, "dispatcher-threads"); - ParsingUtils.setPropertyValue(element, builder, "enable-batch-conflation"); - ParsingUtils.setPropertyValue(element, builder, "manual-start"); - ParsingUtils.setPropertyValue(element, builder, "maximum-queue-memory"); - ParsingUtils.setPropertyValue(element, builder, "order-policy"); - ParsingUtils.setPropertyValue(element, builder, "remote-distributed-system-id"); - ParsingUtils.setPropertyValue(element, builder, "socket-buffer-size"); - ParsingUtils.setPropertyValue(element, builder, "socket-read-timeout"); - ParsingUtils.setPropertyValue(element, builder, "persistent"); - ParsingUtils.setPropertyValue(element, builder, "parallel"); - - Element eventFilterElement = DomUtils.getChildElementByTagName(element, "event-filter"); - if (eventFilterElement != null) { - builder.addPropertyValue("eventFilters", - ParsingUtils.parseRefOrNestedBeanDeclaration(parserContext, eventFilterElement, builder)); - } - - ParsingUtils.parseTransportFilters(element, parserContext, builder); - } -} diff --git a/src/main/java/org/springframework/data/gemfire/config/GemfireNamespaceHandler.java b/src/main/java/org/springframework/data/gemfire/config/GemfireNamespaceHandler.java index fe786165..13bd5206 100644 --- a/src/main/java/org/springframework/data/gemfire/config/GemfireNamespaceHandler.java +++ b/src/main/java/org/springframework/data/gemfire/config/GemfireNamespaceHandler.java @@ -61,9 +61,6 @@ class GemfireNamespaceHandler extends NamespaceHandlerSupport { registerBeanDefinitionParser("cache-server", new CacheServerParser()); registerBeanDefinitionParser("transaction-manager", new TransactionManagerParser()); registerBeanDefinitionParser("cq-listener-container", new GemfireListenerContainerParser()); - registerBeanDefinitionParser("async-event-queue", new AsyncEventQueueParser()); - registerBeanDefinitionParser("gateway-sender", new GatewaySenderParser()); - registerBeanDefinitionParser("gateway-receiver", new GatewayReceiverParser()); registerBeanDefinitionParser("function-service", new FunctionServiceParser()); // V6 WAN parsers registerBeanDefinitionParser("gateway-hub", new GatewayHubParser()); diff --git a/src/main/java/org/springframework/data/gemfire/wan/AsyncEventQueueFactoryBean.java b/src/main/java/org/springframework/data/gemfire/wan/AsyncEventQueueFactoryBean.java deleted file mode 100644 index 255b2381..00000000 --- a/src/main/java/org/springframework/data/gemfire/wan/AsyncEventQueueFactoryBean.java +++ /dev/null @@ -1,121 +0,0 @@ -/* - * Copyright 2010-2012 the original author or authors. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.springframework.data.gemfire.wan; - -import org.springframework.util.Assert; - -import com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue; -import com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueueFactory; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.asyncqueue.AsyncEventListener; - -/** - * FactoryBean for creating GemFire {@link AsyncEventQueue}s. - * @author David Turanski - * - */ -public class AsyncEventQueueFactoryBean extends AbstractWANComponentFactoryBean { - - public void setDiskStoreRef(String diskStoreRef) { - this.diskStoreRef = diskStoreRef; - } - - private final AsyncEventListener asyncEventListener; - - private AsyncEventQueue asyncEventQueue; - - private Integer batchSize; - - private Integer maximumQueueMemory; - - private Boolean persistent; - - private String diskStoreRef; - - /** - * - * @param cache the gemfire cache - * @param asyncEventListener required {@link AsyncEventListener} - */ - public AsyncEventQueueFactoryBean(Cache cache, AsyncEventListener asyncEventListener) { - super(cache); - this.asyncEventListener = asyncEventListener; - } - - @Override - public AsyncEventQueue getObject() throws Exception { - return asyncEventQueue; - } - - @Override - public Class getObjectType() { - return AsyncEventQueue.class; - } - - @Override - protected void doInit() { - Assert.notNull(asyncEventListener, "AsyncEventListener cannot be null"); - AsyncEventQueueFactory asyncEventQueueFactory = null; - if (this.factory == null) { - asyncEventQueueFactory = cache.createAsyncEventQueueFactory(); - } else { - asyncEventQueueFactory = (AsyncEventQueueFactory)factory; - } - - if (persistent != null) { - asyncEventQueueFactory.setPersistent(persistent); - } - if (batchSize != null) { - asyncEventQueueFactory.setBatchSize(batchSize); - } - if (diskStoreRef != null) { - persistent = (persistent == null) ? Boolean.TRUE : persistent; - Assert.isTrue(persistent, "specifying a disk store requires persistent property to be true"); - asyncEventQueueFactory.setDiskStoreName(diskStoreRef); - } - - if (maximumQueueMemory != null) { - asyncEventQueueFactory.setMaximumQueueMemory(maximumQueueMemory); - } - - asyncEventQueue = asyncEventQueueFactory.create(name, asyncEventListener); - } - - @Override - public void destroy() throws Exception { - if (!cache.isClosed()) { - try { - asyncEventListener.close(); - } - catch (CacheClosedException cce) { - // nothing to see folks, move on. - } - } - } - - public void setBatchSize(Integer batchSize) { - this.batchSize = batchSize; - } - - public void setMaximumQueueMemory(Integer maximumQueueMemory) { - this.maximumQueueMemory = maximumQueueMemory; - } - - public void setPersistent(Boolean persistent) { - this.persistent = persistent; - } -} diff --git a/src/main/java/org/springframework/data/gemfire/wan/GatewayReceiverFactoryBean.java b/src/main/java/org/springframework/data/gemfire/wan/GatewayReceiverFactoryBean.java deleted file mode 100644 index 81137be1..00000000 --- a/src/main/java/org/springframework/data/gemfire/wan/GatewayReceiverFactoryBean.java +++ /dev/null @@ -1,123 +0,0 @@ -/* - * Copyright 2010-2012 the original author or authors. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.springframework.data.gemfire.wan; - -import java.util.List; - -import org.springframework.util.Assert; -import org.springframework.util.CollectionUtils; - -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.wan.GatewayReceiver; -import com.gemstone.gemfire.cache.wan.GatewayReceiverFactory; -import com.gemstone.gemfire.cache.wan.GatewayTransportFilter; - -/** - * FactoryBean for creating a GemFire {@link GatewayReceiver}. - * - * @author David Turanski - * - */ -public class GatewayReceiverFactoryBean extends AbstractWANComponentFactoryBean { - private GatewayReceiver gatewayReceiver; - - private List transportFilters; - - private Integer startPort; - - private Integer endPort; - - private Integer maximumTimeBetweenPings; - - private Integer socketBufferSize; - - private String bindAddress; - - /** - * - * @param cache - */ - public GatewayReceiverFactoryBean(Cache cache) { - super(cache); - // Bean name not required. - this.name = "gateway-receiver"; - } - - @Override - public GatewayReceiver getObject() throws Exception { - return gatewayReceiver; - } - - @Override - public Class getObjectType() { - return GatewayReceiver.class; - } - - @Override - protected void doInit() { - GatewayReceiverFactory gatewayReceiverFactory = cache.createGatewayReceiverFactory(); - if (!CollectionUtils.isEmpty(transportFilters)) { - for (GatewayTransportFilter transportFilter : transportFilters) { - gatewayReceiverFactory.addGatewayTransportFilter(transportFilter); - } - } - int minPort = (startPort == null) ? GatewayReceiver.DEFAULT_START_PORT : startPort; - int maxPort = (endPort == null) ? GatewayReceiver.DEFAULT_END_PORT : endPort; - Assert.isTrue(minPort <= maxPort, "startPort must be less then or equal to " + maxPort); - gatewayReceiverFactory.setStartPort(minPort); - gatewayReceiverFactory.setEndPort(maxPort); - if (socketBufferSize != null) { - gatewayReceiverFactory.setSocketBufferSize(socketBufferSize); - } - if (maximumTimeBetweenPings != null) { - gatewayReceiverFactory.setMaximumTimeBetweenPings(maximumTimeBetweenPings); - } - if (bindAddress != null) { - gatewayReceiverFactory.setBindAddress(bindAddress); - } - - gatewayReceiver = gatewayReceiverFactory.create(); - } - - public void setGatewayReceiver(GatewayReceiver gatewayReceiver) { - this.gatewayReceiver = gatewayReceiver; - } - - public void setTransportFilters(List transportFilters) { - this.transportFilters = transportFilters; - } - - public void setStartPort(Integer startPort) { - this.startPort = startPort; - } - - public void setEndPort(Integer endPort) { - this.endPort = endPort; - } - - public void setMaximumTimeBetweenPings(Integer maximumTimeBetweenPings) { - this.maximumTimeBetweenPings = maximumTimeBetweenPings; - } - - public void setSocketBufferSize(Integer socketBufferSize) { - this.socketBufferSize = socketBufferSize; - } - - public void setBindAddress(String bindAddress) { - this.bindAddress = bindAddress; - } - -} diff --git a/src/main/java/org/springframework/data/gemfire/wan/GatewaySenderFactoryBean.java b/src/main/java/org/springframework/data/gemfire/wan/GatewaySenderFactoryBean.java deleted file mode 100644 index 829ef50d..00000000 --- a/src/main/java/org/springframework/data/gemfire/wan/GatewaySenderFactoryBean.java +++ /dev/null @@ -1,237 +0,0 @@ -/* - * Copyright 2010-2012 the original author or authors. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.springframework.data.gemfire.wan; - -import java.util.Arrays; -import java.util.List; - -import org.springframework.util.Assert; -import org.springframework.util.CollectionUtils; - -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.util.Gateway; -import com.gemstone.gemfire.cache.wan.GatewayEventFilter; -import com.gemstone.gemfire.cache.wan.GatewaySender; -import com.gemstone.gemfire.cache.wan.GatewaySenderFactory; -import com.gemstone.gemfire.cache.wan.GatewayTransportFilter; - -/** - * FactoryBean for creating a GemFire {@link GatewaySender}. - * @author David Turanski - * - */ -public class GatewaySenderFactoryBean extends AbstractWANComponentFactoryBean { - private static List validOrderPolicyValues = Arrays.asList("KEY", "PARTITION", "THREAD"); - - private GatewaySender gatewaySender; - - private int remoteDistributedSystemId; - - private List eventFilters; - - private List transportFilters; - - private Integer alertThreshold; - - private Boolean enableBatchConflation; - - private Integer batchSize; - - private Integer batchTimeInterval; - - private String diskStoreRef; - - private Boolean diskSynchronous; - - private Integer dispatcherThreads; - - private Boolean manualStart; - - private Integer maximumQueueMemory; - - private String orderPolicy; - - private Boolean parallel; - - private Boolean persistent; - - private Integer socketBufferSize; - - private Integer socketReadTimeout; - - /** - * - * @param cache the Gemfire cache - */ - public GatewaySenderFactoryBean(Cache cache) { - super(cache); - } - - @Override - public GatewaySender getObject() throws Exception { - return gatewaySender; - } - - @Override - public Class getObjectType() { - return GatewaySender.class; - } - - @Override - protected void doInit() { - GatewaySenderFactory gatewaySenderFactory = null; - if (this.factory == null) { - gatewaySenderFactory = cache.createGatewaySenderFactory(); - } else { - gatewaySenderFactory = (GatewaySenderFactory)factory; - } - if (diskStoreRef != null) { - persistent = (persistent == null) ? Boolean.TRUE : persistent; - Assert.isTrue(persistent, "specifying a disk store requires persistent property to be true"); - gatewaySenderFactory.setDiskStoreName(diskStoreRef); - } - - if (diskSynchronous != null) { - persistent = (persistent == null) ? Boolean.TRUE : persistent; - Assert.isTrue(persistent, "specifying a disk synchronous requires persistent property to be true"); - gatewaySenderFactory.setDiskSynchronous(diskSynchronous); - } - - if (persistent != null) { - gatewaySenderFactory.setPersistenceEnabled(persistent); - } - - parallel = (parallel == null) ? Boolean.FALSE : parallel; - - gatewaySenderFactory.setParallel(parallel); - - if (orderPolicy != null) { - Assert.isTrue(parallel, "specifying an order policy requires the parallel property to be true"); - - Assert.isTrue(validOrderPolicyValues.contains(orderPolicy.toUpperCase()), "The value of order policy:'" - + orderPolicy + "' is invalid"); - gatewaySenderFactory.setOrderPolicy(Gateway.OrderPolicy.valueOf(orderPolicy.toUpperCase())); - } - - if (!CollectionUtils.isEmpty(eventFilters)) { - for (GatewayEventFilter eventFilter : eventFilters) { - gatewaySenderFactory.addGatewayEventFilter(eventFilter); - } - } - if (!CollectionUtils.isEmpty(transportFilters)) { - for (GatewayTransportFilter transportFilter : transportFilters) { - gatewaySenderFactory.addGatewayTransportFilter(transportFilter); - } - } - if (alertThreshold != null) { - gatewaySenderFactory.setAlertThreshold(alertThreshold); - } - if (enableBatchConflation != null) { - gatewaySenderFactory.setBatchConflationEnabled(enableBatchConflation); - } - if (batchSize != null) { - gatewaySenderFactory.setBatchSize(batchSize); - } - if (batchTimeInterval != null) { - gatewaySenderFactory.setBatchTimeInterval(batchTimeInterval); - } - if (dispatcherThreads != null) { - gatewaySenderFactory.setDispatcherThreads(dispatcherThreads); - } - if (manualStart != null) { - gatewaySenderFactory.setManualStart(manualStart); - } - if (maximumQueueMemory != null) { - gatewaySenderFactory.setMaximumQueueMemory(maximumQueueMemory); - } - if (socketBufferSize != null) { - gatewaySenderFactory.setSocketBufferSize(socketBufferSize); - } - if (socketReadTimeout != null) { - gatewaySenderFactory.setSocketReadTimeout(socketReadTimeout); - } - gatewaySender = gatewaySenderFactory.create(name, remoteDistributedSystemId); - } - - public void setRemoteDistributedSystemId(int remoteDistributedSystemId) { - this.remoteDistributedSystemId = remoteDistributedSystemId; - } - - public void setEventFilters(List gatewayEventFilters) { - this.eventFilters = gatewayEventFilters; - } - - public void setTransportFilters(List gatewayTransportFilters) { - this.transportFilters = gatewayTransportFilters; - } - - public void setAlertThreshold(Integer alertThreshold) { - this.alertThreshold = alertThreshold; - } - - public void setEnableBatchConflation(Boolean enableBatchConflation) { - this.enableBatchConflation = enableBatchConflation; - } - - public void setBatchSize(Integer batchSize) { - this.batchSize = batchSize; - } - - public void setBatchTimeInterval(Integer batchTimeInterval) { - this.batchTimeInterval = batchTimeInterval; - } - - public void setDiskStoreRef(String diskStoreRef) { - this.diskStoreRef = diskStoreRef; - } - - public void setDiskSynchronous(Boolean diskSynchronous) { - this.diskSynchronous = diskSynchronous; - } - - public void setDispatcherThreads(Integer dispatcherThreads) { - this.dispatcherThreads = dispatcherThreads; - } - - public void setManualStart(Boolean manualStart) { - this.manualStart = manualStart; - } - - public void setMaximumQueueMemory(Integer maximumQueueMemory) { - this.maximumQueueMemory = maximumQueueMemory; - } - - public void setOrderPolicy(String orderPolicy) { - this.orderPolicy = orderPolicy; - } - - public void setParallel(Boolean parallel) { - this.parallel = parallel; - } - - public void setPersistent(Boolean persistent) { - this.persistent = persistent; - } - - public void setSocketBufferSize(Integer socketBufferSize) { - this.socketBufferSize = socketBufferSize; - } - - public void setSocketReadTimeout(Integer socketReadTimeout) { - this.socketReadTimeout = socketReadTimeout; - } - -}