[camel-kafka-connector] branch master updated: Avoid creating everything from scratch for every Cassandra sink test

[orpiske]

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new 5469e2c  Avoid creating everything from scratch for every Cassandra 
sink test
5469e2c is described below

commit 5469e2ca71289f98468cbdcc9171191e9c229899
Author: Otavio Rodolfo Piske <opi...@redhat.com>
AuthorDate: Tue Feb 9 17:24:55 2021 +0100

    Avoid creating everything from scratch for every Cassandra sink test
---
 .../cassandra/sink/CamelSinkCassandraITCase.java            | 13 +++++++++----
 1 file changed, 9 insertions(+), 4 deletions(-)

diff --git 
a/tests/itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/sink/CamelSinkCassandraITCase.java
 
b/tests/itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/sink/CamelSinkCassandraITCase.java
index b88946e..47e2593 100644
--- 
a/tests/itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/sink/CamelSinkCassandraITCase.java
+++ 
b/tests/itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/sink/CamelSinkCassandraITCase.java
@@ -28,6 +28,7 @@ import org.apache.camel.kafkaconnector.common.utils.TestUtils;
 import org.apache.camel.test.infra.cassandra.services.CassandraService;
 import org.apache.camel.test.infra.cassandra.services.CassandraServiceFactory;
 import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.TestInstance;
@@ -58,18 +59,22 @@ public class CamelSinkCassandraITCase extends 
CamelSinkTestSupport {
         return new String[] {"camel-cql-kafka-connector"};
     }
 
-    @BeforeEach
-    public void setUp() {
-        topicName = getTopicForTest(this);
+    @BeforeAll
+    public void setUpTestData() {
         cassandraClient = new 
CassandraClient(cassandraService.getCassandraHost(), 
cassandraService.getCQL3Port());
 
         testDataDao = cassandraClient.newTestDataDao();
 
         testDataDao.createKeySpace();
         testDataDao.useKeySpace();
-        testDataDao.createTable();
+    }
 
+    @BeforeEach
+    public void setUp() {
+        topicName = getTopicForTest(this);
         received = 0;
+
+        testDataDao.createTable();
     }
 
     @AfterEach