diff --git a/src/main/java/org/springframework/data/gemfire/wan/GatewaySenderWrapper.java b/src/main/java/org/springframework/data/gemfire/wan/GatewaySenderWrapper.java index cf86bebb..c0a7d5bd 100644 --- a/src/main/java/org/springframework/data/gemfire/wan/GatewaySenderWrapper.java +++ b/src/main/java/org/springframework/data/gemfire/wan/GatewaySenderWrapper.java @@ -22,6 +22,9 @@ import org.apache.geode.cache.wan.GatewayTransportFilter; import org.springframework.util.Assert; /** + * {@link GatewaySenderWrapper} is an Adapter around a {@link GatewaySender} providing the ability to control + * manual start and stop. + * * @author David Turanski * @author John Blum * @see org.apache.geode.cache.util.Gateway @@ -33,162 +36,268 @@ public class GatewaySenderWrapper implements GatewaySender { private final GatewaySender delegate; - public GatewaySenderWrapper(final GatewaySender gatewaySender) { - Assert.notNull(gatewaySender, "The target Gateway Sender must not be null."); - this.delegate = gatewaySender; - } - - @Override - public void start() { - delegate.start(); - } - - @Override - public void stop() { - delegate.stop(); - } - - @Override - public void pause() { - delegate.pause(); - } - - @Override - public void resume() { - delegate.resume(); - } - - @Override - public void rebalance() { - delegate.rebalance(); - } - - @Override - public boolean isRunning() { - return delegate.isRunning(); - } - - @Override - public boolean isPaused() { - return delegate.isPaused(); - } - - @Override - public void addGatewayEventFilter(GatewayEventFilter filter) { - delegate.addGatewayEventFilter(filter); - } - - @Override - public void removeGatewayEventFilter(GatewayEventFilter filter) { - delegate.removeGatewayEventFilter(filter); - } - - @Override - public String getId() { - return delegate.getId(); - } - - @Override - public int getRemoteDSId() { - return delegate.getRemoteDSId(); - } - - @Override - public int getSocketBufferSize() { - return delegate.getSocketBufferSize(); - } - - @Override - public int getSocketReadTimeout() { - return delegate.getSocketReadTimeout(); - } - - @Override - public String getDiskStoreName() { - return delegate.getDiskStoreName(); - } - - @Override - public int getMaximumQueueMemory() { - return delegate.getMaximumQueueMemory(); - } - - @Override - public int getBatchSize() { - return delegate.getBatchSize(); - } - - @Override - public int getBatchTimeInterval() { - return delegate.getBatchTimeInterval(); + /** + * Constructs an instance of {@link GatewaySenderWrapper} initialized with the given {@link GatewaySender} to adapt. + * + * @param gatewaySender {@link GatewaySender} to adapt. + * @throws IllegalArgumentException if {@link GatewaySender} is {@literal null}. + * @see org.apache.geode.cache.wan.GatewaySender + */ + public GatewaySenderWrapper(GatewaySender gatewaySender) { + Assert.notNull(gatewaySender, "GatewaySender must not be null"); + this.delegate = gatewaySender; } + /** + * @inheritDoc + */ @Override public boolean isBatchConflationEnabled() { - return delegate.isBatchConflationEnabled(); - } - - @Override - public boolean isPersistenceEnabled() { - return delegate.isPersistenceEnabled(); - } - - @Override - public int getAlertThreshold() { - return delegate.getAlertThreshold(); - } - - @Override - public List getGatewayEventFilters() { - return delegate.getGatewayEventFilters(); - } - - public GatewayEventSubstitutionFilter getGatewayEventSubstitutionFilter() { - return delegate.getGatewayEventSubstitutionFilter(); - } - - @Override - public List getGatewayTransportFilters() { - return delegate.getGatewayTransportFilters(); + return this.delegate.isBatchConflationEnabled(); } + /** + * @inheritDoc + */ @Override public boolean isDiskSynchronous() { - return delegate.isDiskSynchronous(); + return this.delegate.isDiskSynchronous(); } + /** + * @inheritDoc + */ @Override public boolean isManualStart() { return this.manualStart; } + /** + * @inheritDoc + */ @Override public boolean isParallel() { - return delegate.isParallel(); + return this.delegate.isParallel(); } + /** + * @inheritDoc + */ + @Override + public boolean isPaused() { + return this.delegate.isPaused(); + } + + /** + * @inheritDoc + */ + @Override + public boolean isPersistenceEnabled() { + return this.delegate.isPersistenceEnabled(); + } + + /** + * @inheritDoc + */ + @Override + public boolean isRunning() { + return this.delegate.isRunning(); + } + + /** + * @inheritDoc + */ + @Override + public int getAlertThreshold() { + return this.delegate.getAlertThreshold(); + } + + /** + * @inheritDoc + */ + @Override + public int getBatchSize() { + return this.delegate.getBatchSize(); + } + + /** + * @inheritDoc + */ + @Override + public int getBatchTimeInterval() { + return this.delegate.getBatchTimeInterval(); + } + + /** + * @inheritDoc + */ + @Override + public String getDiskStoreName() { + return this.delegate.getDiskStoreName(); + } + + /** + * @inheritDoc + */ @Override public int getDispatcherThreads() { return delegate.getDispatcherThreads(); } + /** + * @inheritDoc + */ @Override - @SuppressWarnings("deprecation") - public GatewaySender.OrderPolicy getOrderPolicy() { - return delegate.getOrderPolicy(); + public List getGatewayEventFilters() { + return this.delegate.getGatewayEventFilters(); + } + + /** + * @inheritDoc + */ + @Override + public GatewayEventSubstitutionFilter getGatewayEventSubstitutionFilter() { + return this.delegate.getGatewayEventSubstitutionFilter(); + } + + /** + * @inheritDoc + */ + @Override + public List getGatewayTransportFilters() { + return this.delegate.getGatewayTransportFilters(); + } + + /** + * @inheritDoc + */ + @Override + public String getId() { + return this.delegate.getId(); } public void setManualStart(boolean manualStart) { this.manualStart = manualStart; } - @Override - public int getMaxParallelismForReplicatedRegion() { - return delegate.getMaxParallelismForReplicatedRegion(); - } + /** + * @inheritDoc + */ + @Override + public int getMaxParallelismForReplicatedRegion() { + return this.delegate.getMaxParallelismForReplicatedRegion(); + } - @Override - public String toString() { - return this.delegate.toString(); - } + /** + * @inheritDoc + */ + @Override + public int getMaximumQueueMemory() { + return this.delegate.getMaximumQueueMemory(); + } + + /** + * @inheritDoc + */ + @Override + @SuppressWarnings("deprecation") + public GatewaySender.OrderPolicy getOrderPolicy() { + return delegate.getOrderPolicy(); + } + + /** + * @inheritDoc + */ + @Override + public int getRemoteDSId() { + return this.delegate.getRemoteDSId(); + } + + /** + * @inheritDoc + */ + @Override + public int getSocketBufferSize() { + return this.delegate.getSocketBufferSize(); + } + + /** + * @inheritDoc + */ + @Override + public int getSocketReadTimeout() { + return this.delegate.getSocketReadTimeout(); + } + + /** + * @inheritDoc + */ + @Override + public void addGatewayEventFilter(GatewayEventFilter filter) { + delegate.addGatewayEventFilter(filter); + } + + /** + * @inheritDoc + */ + @Override + public void removeGatewayEventFilter(GatewayEventFilter filter) { + delegate.removeGatewayEventFilter(filter); + } + + /** + * @inheritDoc + */ + @Override + public void destroy() { + this.delegate.destroy(); + } + + /** + * @inheritDoc + */ + @Override + public void pause() { + delegate.pause(); + } + + /** + * @inheritDoc + */ + @Override + public void rebalance() { + delegate.rebalance(); + } + + /** + * @inheritDoc + */ + @Override + public void resume() { + delegate.resume(); + } + + /** + * @inheritDoc + */ + @Override + public void start() { + delegate.start(); + } + + /** + * @inheritDoc + */ + @Override + public void stop() { + delegate.stop(); + } + + /** + * @inheritDoc + */ + @Override + public String toString() { + return this.delegate.toString(); + } }