Migrate examples to JUnit Jupiter (#7417)

Co-authored-by: Eddú Meléndez Gonzales <[email protected]>

Author: samed-bicer

examples/hazelcast/build.gradle

@@ -11,4 +11,9 @@ dependencies {
     testImplementation 'com.hazelcast:hazelcast:5.2.3'
     testImplementation 'ch.qos.logback:logback-classic:1.3.8'
     testImplementation 'org.assertj:assertj-core:3.24.2'
+    testImplementation 'org.junit.jupiter:junit-jupiter:5.10.0'
+}
+
+test {
+    useJUnitPlatform()
 }

examples/hazelcast/src/test/java/org/testcontainers/examples/HazelcastTest.java

@@ -3,8 +3,8 @@
 import com.hazelcast.client.HazelcastClient;
 import com.hazelcast.client.config.ClientConfig;
 import com.hazelcast.core.HazelcastInstance;
-import org.junit.After;
-import org.junit.Test;
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.Test;
 import org.testcontainers.containers.GenericContainer;
 import org.testcontainers.containers.Network;
 import org.testcontainers.containers.wait.strategy.Wait;
@@ -18,7 +18,7 @@
 /**
  * Examples with Hazelcast using both a single container and a cluster with two containers.
  */
-public class HazelcastTest {
+class HazelcastTest {
 
     // Hazelcast values
     private static final String HZ_IMAGE_NAME = "hazelcast/hazelcast:5.2.0";
@@ -46,13 +46,13 @@ public class HazelcastTest {
 
     private static final String TRUE_VALUE = "true";
 
-    @After
-    public void cleanUp() {
+    @AfterEach
+    void cleanUp() {
         HazelcastClient.shutdownAll();
     }
 
     @Test
-    public void singleHazelcastContainer() {
+    void singleHazelcastContainer() {
         try (
             GenericContainer<?> container = new GenericContainer<>(DockerImageName.parse(HZ_IMAGE_NAME))
                 .withExposedPorts(DEFAULT_EXPOSED_PORT)
@@ -76,7 +76,7 @@ public void singleHazelcastContainer() {
     }
 
     @Test
-    public void hazelcastCluster() {
+    void hazelcastCluster() {
         Network network = Network.newNetwork();
         try (
             GenericContainer<?> container1 = new GenericContainer<>(DockerImageName.parse(HZ_IMAGE_NAME))

examples/immudb/build.gradle

@@ -9,7 +9,13 @@ repositories {
 dependencies {
     implementation 'io.codenotary:immudb4j:1.0.0'
     testImplementation 'org.testcontainers:testcontainers'
+    testImplementation 'org.testcontainers:junit-jupiter'
     testImplementation 'org.assertj:assertj-core:3.24.2'
     testImplementation 'com.google.guava:guava:23.0'
     testImplementation 'ch.qos.logback:logback-classic:1.3.8'
+    testImplementation 'org.junit.jupiter:junit-jupiter:5.10.0'
+}
+
+test {
+    useJUnitPlatform()
 }

examples/immudb/src/test/java/ImmuDbTest.java

@@ -1,20 +1,22 @@
 import io.codenotary.immudb4j.Entry;
 import io.codenotary.immudb4j.ImmuClient;
 import io.codenotary.immudb4j.exceptions.VerificationException;
-import org.junit.After;
-import org.junit.Assert;
-import org.junit.Before;
-import org.junit.ClassRule;
-import org.junit.Test;
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
 import org.testcontainers.containers.GenericContainer;
 import org.testcontainers.containers.wait.strategy.Wait;
+import org.testcontainers.junit.jupiter.Container;
+import org.testcontainers.junit.jupiter.Testcontainers;
 
 import static org.assertj.core.api.Assertions.assertThat;
 
 /**
  * Test class for the ImmuDbClient.
  */
-public class ImmuDbTest {
+@Testcontainers
+class ImmuDbTest {
 
     // Default port for the ImmuDb server
     private static final int IMMUDB_PORT = 3322;
@@ -29,16 +31,16 @@ public class ImmuDbTest {
     private final String IMMUDB_DATABASE = "defaultdb";
 
     // Test container for the ImmuDb database, with the latest version of the image and exposed port
-    @ClassRule
+    @Container
     public static final GenericContainer<?> immuDbContainer = new GenericContainer<>("codenotary/immudb:1.3")
         .withExposedPorts(IMMUDB_PORT)
         .waitingFor(Wait.forLogMessage(".*Web API server enabled.*", 1));
 
     // ImmuClient used to interact with the DB
     private ImmuClient immuClient;
 
-    @Before
-    public void setUp() {
+    @BeforeEach
+    void setUp() {
         this.immuClient =
             ImmuClient
                 .newBuilder()
@@ -48,13 +50,13 @@ public void setUp() {
         this.immuClient.openSession(IMMUDB_DATABASE, IMMUDB_USER, IMMUDB_PASSWORD);
     }
 
-    @After
-    public void tearDown() {
+    @AfterEach
+    void tearDown() {
         this.immuClient.closeSession();
     }
 
     @Test
-    public void testGetValue() {
+    void testGetValue() {
         try {
             immuClient.set("test1", "test2".getBytes());
 
@@ -64,10 +66,10 @@ public void testGetValue() {
                 byte[] value = entry.getValue();
                 assertThat(new String(value)).isEqualTo("test2");
             } else {
-                Assert.fail();
+                Assertions.fail();
             }
         } catch (VerificationException e) {
-            Assert.fail();
+            Assertions.fail();
         }
     }
 }

examples/kafka-cluster/build.gradle

@@ -14,4 +14,9 @@ dependencies {
     testImplementation 'org.assertj:assertj-core:3.24.2'
     testImplementation 'com.google.guava:guava:23.0'
     testImplementation 'ch.qos.logback:logback-classic:1.3.8'
+    testImplementation 'org.junit.jupiter:junit-jupiter:5.10.0'
+}
+
+test {
+    useJUnitPlatform()
 }

examples/kafka-cluster/src/test/java/com/example/kafkacluster/KafkaContainerClusterTest.java

@@ -13,7 +13,7 @@
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.common.serialization.StringDeserializer;
 import org.apache.kafka.common.serialization.StringSerializer;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
 import org.rnorth.ducttape.unreliables.Unreliables;
 
 import java.time.Duration;
@@ -25,10 +25,10 @@
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.tuple;
 
-public class KafkaContainerClusterTest {
+class KafkaContainerClusterTest {
 
     @Test
-    public void testKafkaContainerCluster() throws Exception {
+    void testKafkaContainerCluster() throws Exception {
         try (KafkaContainerCluster cluster = new KafkaContainerCluster("6.2.1", 3, 2)) {
             cluster.start();
             String bootstrapServers = cluster.getBootstrapServers();
@@ -40,7 +40,7 @@ public void testKafkaContainerCluster() throws Exception {
     }
 
     @Test
-    public void testKafkaContainerKraftCluster() throws Exception {
+    void testKafkaContainerKraftCluster() throws Exception {
         try (KafkaContainerKraftCluster cluster = new KafkaContainerKraftCluster("7.0.0", 3, 2)) {
             cluster.start();
             String bootstrapServers = cluster.getBootstrapServers();
@@ -52,7 +52,7 @@ public void testKafkaContainerKraftCluster() throws Exception {
     }
 
     @Test
-    public void testKafkaContainerKraftClusterAfterConfluentPlatform740() throws Exception {
+    void testKafkaContainerKraftClusterAfterConfluentPlatform740() throws Exception {
         try (KafkaContainerKraftCluster cluster = new KafkaContainerKraftCluster("7.4.0", 3, 2)) {
             cluster.start();
             String bootstrapServers = cluster.getBootstrapServers();

examples/nats/build.gradle

@@ -12,4 +12,9 @@ dependencies {
     testImplementation 'io.nats:jnats:2.16.13'
     testImplementation 'ch.qos.logback:logback-classic:1.3.8'
     testImplementation 'org.apache.httpcomponents:httpclient:4.5.14'
+    testImplementation 'org.junit.jupiter:junit-jupiter:5.10.0'
+}
+
+test {
+    useJUnitPlatform()
 }

examples/nats/src/test/java/com/example/NatsContainerTest.java

@@ -8,21 +8,21 @@
 import org.apache.http.client.methods.HttpGet;
 import org.apache.http.client.methods.HttpUriRequest;
 import org.apache.http.impl.client.HttpClientBuilder;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
 import org.testcontainers.containers.GenericContainer;
 
 import java.io.IOException;
 
 import static org.assertj.core.api.Assertions.assertThat;
 
-public class NatsContainerTest {
+class NatsContainerTest {
 
     public static final Integer NATS_PORT = 4222;
 
     public static final Integer NATS_MGMT_PORT = 8222;
 
     @Test
-    public void test() throws IOException, InterruptedException {
+    void test() throws IOException, InterruptedException {
         try (
             GenericContainer<?> nats = new GenericContainer<>("nats:2.9.8-alpine3.16")
                 .withExposedPorts(NATS_PORT, NATS_MGMT_PORT)
@@ -38,7 +38,7 @@ public void test() throws IOException, InterruptedException {
     }
 
     @Test
-    public void testServerStatus() throws IOException {
+    void testServerStatus() throws IOException {
         try (
             GenericContainer<?> nats = new GenericContainer<>("nats:2.9.8-alpine3.16")
                 .withExposedPorts(NATS_PORT, NATS_MGMT_PORT)

examples/redis-backed-cache/build.gradle

@@ -12,7 +12,12 @@ dependencies {
     implementation 'com.google.code.gson:gson:2.10.1'
     implementation 'com.google.guava:guava:23.0'
     testImplementation 'org.testcontainers:testcontainers'
-    testImplementation 'junit:junit:4.13.2'
+    testImplementation 'org.testcontainers:junit-jupiter'
+    testImplementation 'org.junit.jupiter:junit-jupiter:5.10.0'
     testImplementation 'ch.qos.logback:logback-classic:1.3.8'
     testImplementation 'org.assertj:assertj-core:3.24.2'
 }
+
+test {
+    useJUnitPlatform()
+}

examples/redis-backed-cache/src/test/java/RedisBackedCacheTest.java

@@ -1,9 +1,10 @@
 import com.mycompany.cache.Cache;
 import com.mycompany.cache.RedisBackedCache;
-import org.junit.Before;
-import org.junit.Rule;
-import org.junit.Test;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
 import org.testcontainers.containers.GenericContainer;
+import org.testcontainers.junit.jupiter.Container;
+import org.testcontainers.junit.jupiter.Testcontainers;
 import org.testcontainers.utility.DockerImageName;
 import redis.clients.jedis.Jedis;
 
@@ -14,23 +15,24 @@
 /**
  * Integration test for Redis-backed cache implementation.
  */
-public class RedisBackedCacheTest {
+@Testcontainers
+class RedisBackedCacheTest {
 
-    @Rule
+    @Container
     public GenericContainer<?> redis = new GenericContainer<>(DockerImageName.parse("redis:3.0.6"))
         .withExposedPorts(6379);
 
     private Cache cache;
 
-    @Before
-    public void setUp() throws Exception {
+    @BeforeEach
+    void setUp() throws Exception {
         Jedis jedis = new Jedis(redis.getHost(), redis.getMappedPort(6379));
 
         cache = new RedisBackedCache(jedis, "test");
     }
 
     @Test
-    public void testFindingAnInsertedValue() {
+    void testFindingAnInsertedValue() {
         cache.put("foo", "FOO");
         Optional<String> foundObject = cache.get("foo", String.class);
 
@@ -41,7 +43,7 @@ public void testFindingAnInsertedValue() {
     }
 
     @Test
-    public void testNotFindingAValueThatWasNotInserted() {
+    void testNotFindingAValueThatWasNotInserted() {
         Optional<String> foundObject = cache.get("bar", String.class);
 
         assertThat(foundObject.isPresent())