From 67f4ef10ffd360e88cd50e10da5ae842c4412717 Mon Sep 17 00:00:00 2001 From: John Blum Date: Fri, 12 May 2023 10:28:13 -0700 Subject: [PATCH] Refactor Testcontainers Cassandra Configuration. --- .../app/crm/config/TestCassandraConfiguration.java | 6 +++--- .../config/TestcontainersCassandraConfiguration.java | 12 +++++++----- 2 files changed, 10 insertions(+), 8 deletions(-) diff --git a/spring-geode-project/spring-geode/src/test/java/example/app/crm/config/TestCassandraConfiguration.java b/spring-geode-project/spring-geode/src/test/java/example/app/crm/config/TestCassandraConfiguration.java index 7335da18..c1a5615e 100644 --- a/spring-geode-project/spring-geode/src/test/java/example/app/crm/config/TestCassandraConfiguration.java +++ b/spring-geode-project/spring-geode/src/test/java/example/app/crm/config/TestCassandraConfiguration.java @@ -20,9 +20,6 @@ import static org.assertj.core.api.Assertions.assertThat; import java.util.Optional; import java.util.function.Consumer; -import com.datastax.oss.driver.api.core.CqlIdentifier; -import com.datastax.oss.driver.api.core.session.Session; - import org.springframework.beans.BeansException; import org.springframework.beans.factory.config.BeanPostProcessor; import org.springframework.context.ApplicationListener; @@ -41,6 +38,9 @@ import org.springframework.data.cassandra.core.cql.session.init.ResourceKeyspace import org.springframework.data.cassandra.core.cql.session.init.SessionFactoryInitializer; import org.springframework.lang.NonNull; +import com.datastax.oss.driver.api.core.CqlIdentifier; +import com.datastax.oss.driver.api.core.session.Session; + import example.app.crm.model.Customer; import example.app.crm.repo.CustomerRepository; diff --git a/spring-geode-project/spring-geode/src/test/java/example/app/crm/config/TestcontainersCassandraConfiguration.java b/spring-geode-project/spring-geode/src/test/java/example/app/crm/config/TestcontainersCassandraConfiguration.java index 4e3b6905..1633f634 100644 --- a/spring-geode-project/spring-geode/src/test/java/example/app/crm/config/TestcontainersCassandraConfiguration.java +++ b/spring-geode-project/spring-geode/src/test/java/example/app/crm/config/TestcontainersCassandraConfiguration.java @@ -20,8 +20,6 @@ import static org.assertj.core.api.Assertions.assertThat; import java.net.InetSocketAddress; import java.util.Arrays; -import com.datastax.oss.driver.api.core.CqlSession; - import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.boot.autoconfigure.cassandra.CassandraProperties; import org.springframework.boot.autoconfigure.cassandra.CqlSessionBuilderCustomizer; @@ -33,8 +31,11 @@ import org.springframework.core.env.Environment; import org.springframework.data.cassandra.core.CassandraTemplate; import org.springframework.lang.NonNull; +import com.datastax.oss.driver.api.core.CqlSession; + import org.testcontainers.containers.CassandraContainer; import org.testcontainers.containers.GenericContainer; +import org.testcontainers.utility.DockerImageName; import example.app.crm.model.Customer; @@ -59,8 +60,9 @@ import example.app.crm.model.Customer; @SuppressWarnings("unused") public class TestcontainersCassandraConfiguration extends TestCassandraConfiguration { - //private static final String CASSANDRA_DOCKER_IMAGE_NAME = "cassandra:latest"; - private static final String CASSANDRA_DOCKER_IMAGE_NAME = "cassandra:3.11.15"; + //private static final DockerImageName CASSANDRA_DOCKER_IMAGE_NAME = DockerImageName.parse("cassandra:latest"); + private static final DockerImageName CASSANDRA_DOCKER_IMAGE_NAME = DockerImageName.parse("cassandra:3.11.15"); + private static final String LOCAL_DATACENTER_NAME = "datacenter1"; @Bean("CassandraContainer") @@ -86,7 +88,7 @@ public class TestcontainersCassandraConfiguration extends TestCassandraConfigura private @NonNull GenericContainer newEnvironmentOptimizedCassandraContainer() { return newCassandraContainer() - .withEnv("CASSANDRA_SNITCH", "GossipingPropertyFileSnitch") + .withEnv("CASSANDRA_SNITCH", "SimpleSnitch") .withEnv("HEAP_NEWSIZE", "128M") .withEnv("MAX_HEAP_SIZE", "1024M") .withEnv("JVM_OPTS", "-Dcassandra.skip_wait_for_gossip_to_settle=0 -Dcassandra.initial_token=0");