Spring/spring-data-cassandra
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DATACASS-238 - Polishing.

Browse Source 
Reformat field declarations. Add/enhance JavaDoc. Add since tags to the new methods.

Original pull requests: #79, #80.
This commit is contained in:
Mark Paluch
2016-07-26 11:32:27 +02:00
parent 58ed9789de
commit 7d5b79b9e4
2 changed files with 95 additions and 62 deletions
Download Patch File Download Diff File Expand all files Collapse all files

101
spring-cql/src/main/java/org/springframework/cassandra/config/CassandraCqlClusterFactoryBean.java
View File

@@ -36,6 +36,7 @@ import org.springframework.cassandra.core.util.CollectionUtils;
import org.springframework.cassandra.support.CassandraExceptionTranslator;
import org.springframework.dao.DataAccessException;
import org.springframework.dao.support.PersistenceExceptionTranslator;
import org.springframework.util.Assert;
import org.springframework.util.StringUtils;
import com.datastax.driver.core.AuthProvider;
@@ -44,13 +45,14 @@ import com.datastax.driver.core.Host;
import com.datastax.driver.core.LatencyTracker;
import com.datastax.driver.core.NettyOptions;
import com.datastax.driver.core.PoolingOptions;
import com.datastax.driver.core.ProtocolOptions.Compression;
import com.datastax.driver.core.ProtocolVersion;
import com.datastax.driver.core.QueryOptions;
import com.datastax.driver.core.SSLOptions;
import com.datastax.driver.core.Session;
import com.datastax.driver.core.SocketOptions;
import com.datastax.driver.core.TimestampGenerator;
import com.datastax.driver.core.Cluster.Builder;
import com.datastax.driver.core.ProtocolOptions.Compression;
import com.datastax.driver.core.policies.AddressTranslator;
import com.datastax.driver.core.policies.LoadBalancingPolicy;
import com.datastax.driver.core.policies.ReconnectionPolicy;
@@ -95,48 +97,35 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
private int maxSchemaAgreementWaitSeconds = DEFAULT_MAX_SCHEMA_AGREEMENT_WAIT_SECONDS;
private int port = DEFAULT_PORT;
private AddressTranslator addressTranslator;
private AuthProvider authProvider;
private final PersistenceExceptionTranslator exceptionTranslator = new CassandraExceptionTranslator();
private Cluster cluster;
private ClusterBuilderConfigurer clusterBuilderConfigurer;
private AddressTranslator addressTranslator;
private AuthProvider authProvider;
private CompressionType compressionType;
private Host.StateListener hostStateListener;
private LatencyTracker latencyTracker;
private List<CreateKeyspaceSpecification> keyspaceCreations = new ArrayList<CreateKeyspaceSpecification>();
private List<DropKeyspaceSpecification> keyspaceDrops = new ArrayList<DropKeyspaceSpecification>();
private Set<KeyspaceActionSpecification<?>> keyspaceSpecifications = new HashSet<KeyspaceActionSpecification<?>>();
private List<String> startupScripts = new ArrayList<String>();
private List<String> shutdownScripts = new ArrayList<String>();
private LoadBalancingPolicy loadBalancingPolicy;
private NettyOptions nettyOptions;
private final PersistenceExceptionTranslator exceptionTranslator = new CassandraExceptionTranslator();
private PoolingOptions poolingOptions;
private ProtocolVersion protocolVersion;
private QueryOptions queryOptions;
private ReconnectionPolicy reconnectionPolicy;
private RetryPolicy retryPolicy;
private Set<KeyspaceActionSpecification<?>> keyspaceSpecifications = new HashSet<KeyspaceActionSpecification<?>>();
private SpeculativeExecutionPolicy speculativeExecutionPolicy;
private SocketOptions socketOptions;
private SSLOptions sslOptions;
private TimestampGenerator timestampGenerator;
private String beanName;
private String clusterName;
@@ -144,8 +133,6 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
private String password;
private String username;
private TimestampGenerator timestampGenerator;
/*
* (non-Javadoc)
* @see org.springframework.beans.factory.InitializingBean#afterPropertiesSet()
@@ -153,9 +140,7 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
@Override
public void afterPropertiesSet() throws Exception {
if (!StringUtils.hasText(contactPoints)) {
throw new IllegalArgumentException("At least one server is required");
}
Assert.isTrue(StringUtils.hasText(contactPoints), "At least one server is required");
Cluster.Builder clusterBuilder = newClusterBuilder();
@@ -266,7 +251,7 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
return Cluster.builder();
}
String resolveClusterName() {
private String resolveClusterName() {
return (StringUtils.hasText(clusterName) ? clusterName : beanName);
}
@@ -369,6 +354,7 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
/*
* (non-Javadoc)
* @see org.springframework.beans.factory.BeanNameAware#setBeanName(String)
* @since 1.5
*/
@Override
public void setBeanName(String beanName) {
@@ -378,6 +364,8 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
/**
* Set a comma-delimited string of the contact points (hosts) to connect to. Default is {@code localhost};
* see {@link #DEFAULT_CONTACT_POINTS}.
*
* @param contactPoints the contact points used by the new cluster.
*/
public void setContactPoints(String contactPoints) {
this.contactPoints = contactPoints;
@@ -385,6 +373,8 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
/**
* Set the port for the contact points. Default is {@code 9042}, see {@link #DEFAULT_PORT}.
*
* @param port the port used by the new cluster.
*/
public void setPort(int port) {
this.port = port;
@@ -392,6 +382,8 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
/**
* Set the {@link CompressionType}. Default is uncompressed.
*
* @param compressionType the {@link CompressionType} used by the new cluster.
*/
public void setCompressionType(CompressionType compressionType) {
this.compressionType = compressionType;
@@ -399,6 +391,8 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
/**
* Set the {@link PoolingOptions} to configure the connection pooling behavior.
*
* @param poolingOptions the {@link PoolingOptions} used by the new cluster.
*/
public void setPoolingOptions(PoolingOptions poolingOptions) {
this.poolingOptions = poolingOptions;
@@ -407,6 +401,7 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
/**
* Set the {@link ProtocolVersion}.
*
* @param protocolVersion the {@link ProtocolVersion} used by the new cluster.
* @since 1.4
*/
public void setProtocolVersion(ProtocolVersion protocolVersion) {
@@ -415,6 +410,8 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
/**
* Set the {@link SocketOptions} containing low-level socket options.
*
* @param socketOptions the {@link SocketOptions} used by the new cluster.
*/
public void setSocketOptions(SocketOptions socketOptions) {
this.socketOptions = socketOptions;
@@ -422,6 +419,8 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
/**
* Set the {@link QueryOptions} to tune to defaults for individual queries.
*
* @param queryOptions the {@link QueryOptions} used by the new cluster.
*/
public void setQueryOptions(QueryOptions queryOptions) {
this.queryOptions = queryOptions;
@@ -429,6 +428,8 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
/**
* Set the {@link AuthProvider}. Default is unauthenticated.
*
* @param authProvider the {@link AuthProvider} used by the new cluster.
*/
public void setAuthProvider(AuthProvider authProvider) {
this.authProvider = authProvider;
@@ -437,6 +438,7 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
/**
* Set the {@link NettyOptions} used by a client to customize the driver's underlying Netty layer.
*
* @param nettyOptions the {@link NettyOptions} used by the new cluster.
* @since 1.5
*/
public void setNettyOptions(NettyOptions nettyOptions) {
@@ -445,6 +447,8 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
/**
* Set the {@link LoadBalancingPolicy} that decides which Cassandra hosts to contact for each new query.
*
* @param loadBalancingPolicy the {@link LoadBalancingPolicy} used by the new cluster.
*/
public void setLoadBalancingPolicy(LoadBalancingPolicy loadBalancingPolicy) {
this.loadBalancingPolicy = loadBalancingPolicy;
@@ -452,6 +456,8 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
/**
* Set the {@link ReconnectionPolicy} that decides how often the reconnection to a dead node is attempted.
*
* @param reconnectionPolicy the {@link ReconnectionPolicy} used by the new cluster.
*/
public void setReconnectionPolicy(ReconnectionPolicy reconnectionPolicy) {
this.reconnectionPolicy = reconnectionPolicy;
@@ -459,6 +465,8 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
/**
* Set the {@link RetryPolicy} that defines a default behavior to adopt when a request fails.
*
* @param retryPolicy the {@link RetryPolicy} used by the new cluster.
*/
public void setRetryPolicy(RetryPolicy retryPolicy) {
this.retryPolicy = retryPolicy;
@@ -476,13 +484,15 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
* this factory is {@link #afterPropertiesSet() initialized}. {@link CreateKeyspaceSpecification Create keyspace
* specifications} are executed on a system session with no keyspace set, before executing
* {@link #setStartupScripts(List)}.
*
* @param specifications the {@link List} of {@link CreateKeyspaceSpecification create keyspace specifications}.
*/
public void setKeyspaceCreations(List<CreateKeyspaceSpecification> specifications) {
this.keyspaceCreations = specifications;
}
/**
* Return a {@link List} of {@link CreateKeyspaceSpecification create keyspace specifications}.
* @return {@link List} of {@link CreateKeyspaceSpecification create keyspace specifications}.
*/
public List<CreateKeyspaceSpecification> getKeyspaceCreations() {
return keyspaceCreations;
@@ -492,13 +502,15 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
* Set a {@link List} of {@link DropKeyspaceSpecification drop keyspace specifications} that are executed when this
* factory is {@link #destroy() destroyed}. {@link DropKeyspaceSpecification Drop keyspace specifications} are
* executed on a system session with no keyspace set, before executing {@link #setShutdownScripts(List)}.
*
* @param specifications the {@link List} of {@link DropKeyspaceSpecification drop keyspace specifications}.
*/
public void setKeyspaceDrops(List<DropKeyspaceSpecification> specifications) {
this.keyspaceDrops = specifications;
}
/**
* Reurn the {@link List} of {@link DropKeyspaceSpecification drop keyspace specifications}.
* @return the {@link List} of {@link DropKeyspaceSpecification drop keyspace specifications}.
*/
public List<DropKeyspaceSpecification> getKeyspaceDrops() {
return keyspaceDrops;
@@ -508,11 +520,17 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
* Set a {@link List} of raw {@link String CQL statements} that are executed when this factory is
* {@link #afterPropertiesSet() initialized}. Scripts are executed on a system session with no keyspace set, after
* executing {@link #setKeyspaceCreations(List)}.
*
* @param scripts the scripts to execute on startup
*/
public void setStartupScripts(List<String> scripts) {
this.startupScripts = scripts;
}
/**
*
* @return the startup scripts
*/
public List<String> getStartupScripts() {
return startupScripts;
}
@@ -521,24 +539,30 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
* Set a {@link List} of raw {@link String CQL statements} that are executed when this factory is {@link #destroy()
* destroyed}. {@link DropKeyspaceSpecification Drop keyspace specifications} are executed on a system session with no
* keyspace set, after executing {@link #setKeyspaceDrops(List)}.
*
* @param scripts the scripts to execute on shutdown
*/
public void setShutdownScripts(List<String> scripts) {
this.shutdownScripts = scripts;
}
/**
*
* @return the shutdown scripts
*/
public List<String> getShutdownScripts() {
return shutdownScripts;
}
/**
* @param keyspaceSpecifications The keyspaceSpecifications to set.
* @param keyspaceSpecifications The {@link KeyspaceActionSpecification} to set.
*/
public void setKeyspaceSpecifications(Set<KeyspaceActionSpecification<?>> keyspaceSpecifications) {
this.keyspaceSpecifications = keyspaceSpecifications;
}
/**
* @return Returns the keyspaceSpecifications.
* @return the {@link KeyspaceActionSpecification} associated with this factory.
*/
public Set<KeyspaceActionSpecification<?>> getKeyspaceSpecifications() {
return keyspaceSpecifications;
@@ -608,17 +632,20 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
* @param addressTranslator {@link AddressTranslator} used by the new cluster.
* @see com.datastax.driver.core.Cluster.Builder#withAddressTranslator(AddressTranslator)
* @see com.datastax.driver.core.policies.AddressTranslator
* @since 1.5
*/
public void setAddressTranslator(AddressTranslator addressTranslator) {
this.addressTranslator = addressTranslator;
}
/**
* Sets the {@link ClusterBuilderConfigurer} used to apply additional configuration logic
* to the {@link com.datastax.driver.core.Cluster.Builder}.
* Sets the {@link ClusterBuilderConfigurer} used to apply additional configuration logic to the
* {@link com.datastax.driver.core.Cluster.Builder}. {@link ClusterBuilderConfigurer} is invoked after all provided
* options are configured. The factory will {@link Builder#build()} the {@link Cluster} after applying
* {@link ClusterBuilderConfigurer}.
*
* @param clusterBuilderConfigurer {@link ClusterBuilderConfigurer} used to configure the
* {@link com.datastax.driver.core.Cluster.Builder}.
* {@link com.datastax.driver.core.Cluster.Builder}.
* @see org.springframework.cassandra.config.ClusterBuilderConfigurer
*/
public void setClusterBuilderConfigurer(ClusterBuilderConfigurer clusterBuilderConfigurer) {
@@ -626,10 +653,11 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
}
/**
* An optional name for the create cluster.
* \
* An optional name for the cluster instance. This name appears in JMX metrics. Defaults to the bean name.
*
* @param clusterName optional name for the cluster.
* @see com.datastax.driver.core.Cluster.Builder#withClusterName(String)
* @since 1.5
*/
public void setClusterName(String clusterName) {
this.clusterName = clusterName;
@@ -641,6 +669,7 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
*
* @param seconds max schema agreement wait in seconds.
* @see com.datastax.driver.core.Cluster.Builder#withMaxSchemaAgreementWaitSeconds(int)
* @since 1.5
*/
public void setMaxSchemaAgreementWaitSeconds(int seconds) {
this.maxSchemaAgreementWaitSeconds = seconds;
@@ -652,6 +681,7 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
* @param speculativeExecutionPolicy {@link SpeculativeExecutionPolicy} to use with the new cluster.
* @see com.datastax.driver.core.Cluster.Builder#withSpeculativeExecutionPolicy(SpeculativeExecutionPolicy)
* @see com.datastax.driver.core.policies.SpeculativeExecutionPolicy
* @since 1.5
*/
public void setSpeculativeExecutionPolicy(SpeculativeExecutionPolicy speculativeExecutionPolicy) {
this.speculativeExecutionPolicy = speculativeExecutionPolicy;
@@ -664,6 +694,7 @@ public class CassandraCqlClusterFactoryBean implements FactoryBean<Cluster>, Ini
* sent with each query.
* @see com.datastax.driver.core.Cluster.Builder#withTimestampGenerator(TimestampGenerator)
* @see com.datastax.driver.core.TimestampGenerator
* @since 1.5
*/
public void setTimestampGenerator(TimestampGenerator timestampGenerator) {
this.timestampGenerator = timestampGenerator;

56
spring-cql/src/test/java/org/springframework/cassandra/config/java/AbstractClusterConfigurationUnitTests.java
View File

@@ -62,7 +62,7 @@ import com.datastax.driver.core.policies.SpeculativeExecutionPolicy;
public class AbstractClusterConfigurationUnitTests {
/**
* @see <a href="https://jira.spring.io/browse/DATACASS-226"></a>
* @see <a href="https://jira.spring.io/browse/DATACASS-226">DATACASS-226</a>
* @throws Exception
*/
@Test
@@ -81,7 +81,7 @@ public class AbstractClusterConfigurationUnitTests {
}
/**
* @see <a href="https://jira.spring.io/browse/DATACASS-226"></a>
* @see <a href="https://jira.spring.io/browse/DATACASS-226">DATACASS-226</a>
* @throws Exception
*/
@Test
@@ -101,7 +101,7 @@ public class AbstractClusterConfigurationUnitTests {
}
/**
* @see <a href="https://jira.spring.io/browse/DATACASS-226"></a>
* @see <a href="https://jira.spring.io/browse/DATACASS-226">DATACASS-226</a>
* @throws Exception
*/
@Test
@@ -121,7 +121,7 @@ public class AbstractClusterConfigurationUnitTests {
}
/**
* @see <a href="https://jira.spring.io/browse/DATACASS-226"></a>
* @see <a href="https://jira.spring.io/browse/DATACASS-226">DATACASS-226</a>
* @throws Exception
*/
@Test
@@ -141,7 +141,7 @@ public class AbstractClusterConfigurationUnitTests {
}
/**
* @see <a href="https://jira.spring.io/browse/DATACASS-226"></a>
* @see <a href="https://jira.spring.io/browse/DATACASS-226">DATACASS-226</a>
* @throws Exception
*/
@Test
@@ -161,7 +161,7 @@ public class AbstractClusterConfigurationUnitTests {
}
/**
* @see <a href="https://jira.spring.io/browse/DATACASS-226"></a>
* @see <a href="https://jira.spring.io/browse/DATACASS-226">DATACASS-226</a>
* @throws Exception
*/
@Test
@@ -181,7 +181,7 @@ public class AbstractClusterConfigurationUnitTests {
}
/**
* @see <a href="https://jira.spring.io/browse/DATACASS-226"></a>
* @see <a href="https://jira.spring.io/browse/DATACASS-226">DATACASS-226</a>
* @throws Exception
*/
@Test
@@ -197,11 +197,11 @@ public class AbstractClusterConfigurationUnitTests {
};
Cluster cluster = getCluster(clusterConfiguration);
assertThat(getConfiguration(cluster).getPolicies().getLoadBalancingPolicy(), is(loadBalancingPolicy));
assertThat(getPolicies(cluster).getLoadBalancingPolicy(), is(loadBalancingPolicy));
}
/**
* @see <a href="https://jira.spring.io/browse/DATACASS-226"></a>
* @see <a href="https://jira.spring.io/browse/DATACASS-226">DATACASS-226</a>
* @throws Exception
*/
@Test
@@ -217,11 +217,11 @@ public class AbstractClusterConfigurationUnitTests {
};
Cluster cluster = getCluster(clusterConfiguration);
assertThat(getConfiguration(cluster).getPolicies().getReconnectionPolicy(), is(reconnectionPolicy));
assertThat(getPolicies(cluster).getReconnectionPolicy(), is(reconnectionPolicy));
}
/**
* @see <a href="https://jira.spring.io/browse/DATACASS-226"></a>
* @see <a href="https://jira.spring.io/browse/DATACASS-226">DATACASS-226</a>
* @throws Exception
*/
@Test
@@ -240,7 +240,7 @@ public class AbstractClusterConfigurationUnitTests {
}
/**
* @see <a href="https://jira.spring.io/browse/DATACASS-226"></a>
* @see <a href="https://jira.spring.io/browse/DATACASS-226">DATACASS-226</a>
* @throws Exception
*/
@Test
@@ -258,11 +258,10 @@ public class AbstractClusterConfigurationUnitTests {
}
/**
* @see <a href="https://jira.spring.io/browse/DATACASS-226"></a>
* @throws Exception
* @see <a href="https://jira.spring.io/browse/DATACASS-226">DATACASS-226</a>
*/
@Test
public void shouldSetKeyspaceCreations() throws Exception {
public void shouldSetKeyspaceCreations() {
final List<CreateKeyspaceSpecification> specification = Collections
.singletonList(CreateKeyspaceSpecification.createKeyspace());
@@ -277,11 +276,10 @@ public class AbstractClusterConfigurationUnitTests {
}
/**
* @see <a href="https://jira.spring.io/browse/DATACASS-226"></a>
* @throws Exception
* @see <a href="https://jira.spring.io/browse/DATACASS-226">DATACASS-226</a>
*/
@Test
public void shouldSetKeyspaceDrops() throws Exception {
public void shouldSetKeyspaceDrops() {
final List<DropKeyspaceSpecification> specification = Collections
.singletonList(DropKeyspaceSpecification.dropKeyspace());
@@ -296,11 +294,10 @@ public class AbstractClusterConfigurationUnitTests {
}
/**
* @see <a href="https://jira.spring.io/browse/DATACASS-226"></a>
* @throws Exception
* @see <a href="https://jira.spring.io/browse/DATACASS-226">DATACASS-226</a>
*/
@Test
public void shouldSetStartupScripts() throws Exception {
public void shouldSetStartupScripts() {
final List<String> scripts = Collections.singletonList("USE BLUE_METH; CREATE TABLE...");
AbstractClusterConfiguration clusterConfiguration = new AbstractClusterConfiguration() {
@@ -314,11 +311,10 @@ public class AbstractClusterConfigurationUnitTests {
}
/**
* @see <a href="https://jira.spring.io/browse/DATACASS-226"></a>
* @throws Exception
* @see <a href="https://jira.spring.io/browse/DATACASS-226">DATACASS-226</a>
*/
@Test
public void shouldSetShutdownScripts() throws Exception {
public void shouldSetShutdownScripts() {
final List<String> scripts = Collections.singletonList("USE BLUE_METH; DROP TABLE...");
AbstractClusterConfiguration clusterConfiguration = new AbstractClusterConfiguration() {
@@ -336,6 +332,7 @@ public class AbstractClusterConfigurationUnitTests {
*/
@Test
public void shouldSetAddressTranslator() throws Exception {
final AddressTranslator mockAddressTranslator = mock(AddressTranslator.class);
AbstractClusterConfiguration clusterConfiguration = new AbstractClusterConfiguration() {
@@ -353,6 +350,7 @@ public class AbstractClusterConfigurationUnitTests {
*/
@Test
public void shouldSetAndApplyClusterBuilderConfigurer() throws Exception {
final ClusterBuilderConfigurer mockClusterBuilderConfigurer = mock(ClusterBuilderConfigurer.class);
AbstractClusterConfiguration clusterConfiguration = new AbstractClusterConfiguration() {
@@ -372,6 +370,7 @@ public class AbstractClusterConfigurationUnitTests {
*/
@Test
public void shouldSetClusterName() throws Exception {
AbstractClusterConfiguration clusterConfiguration = new AbstractClusterConfiguration() {
@Override protected String getClusterName() {
return "testCluster";
@@ -386,6 +385,7 @@ public class AbstractClusterConfigurationUnitTests {
*/
@Test
public void shouldSetMaxSchemaAgreementWaitInSeconds() throws Exception {
AbstractClusterConfiguration clusterConfiguration = new AbstractClusterConfiguration() {
@Override protected int getMaxSchemaAgreementWaitSeconds() {
return 30;
@@ -401,6 +401,7 @@ public class AbstractClusterConfigurationUnitTests {
*/
@Test
public void shouldSetSpeculativeExecutionPolicy() throws Exception {
final SpeculativeExecutionPolicy mockSpeculativeExecutionPolicy = mock(SpeculativeExecutionPolicy.class);
AbstractClusterConfiguration clusterConfiguration = new AbstractClusterConfiguration() {
@@ -418,6 +419,7 @@ public class AbstractClusterConfigurationUnitTests {
*/
@Test
public void shouldSetTimestampGenerator() throws Exception {
final TimestampGenerator mockTimestampGenerator = mock(TimestampGenerator.class);
AbstractClusterConfiguration clusterConfiguration = new AbstractClusterConfiguration() {
@@ -430,15 +432,15 @@ public class AbstractClusterConfigurationUnitTests {
is(equalTo(mockTimestampGenerator)));
}
private Policies getPolicies(Cluster cluster) throws Exception {
private Policies getPolicies(Cluster cluster) {
return getConfiguration(cluster).getPolicies();
}
private ProtocolOptions getProtocolOptions(Cluster cluster) throws Exception {
private ProtocolOptions getProtocolOptions(Cluster cluster) {
return getConfiguration(cluster).getProtocolOptions();
}
private Configuration getConfiguration(Cluster cluster) throws Exception {
private Configuration getConfiguration(Cluster cluster) {
return cluster.getConfiguration();
}