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

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

commit 0ee8710f8c9026531154c74b83742c404c24421d
Author: Otavio Rodolfo Piske <opi...@redhat.com>
AuthorDate: Wed Mar 3 10:12:15 2021 +0100

    Remove duplicate run test method
---
 .../common/test/CamelSourceTestSupport.java              | 16 ----------------
 1 file changed, 16 deletions(-)

diff --git 
a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/CamelSourceTestSupport.java
 
b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/CamelSourceTestSupport.java
index 016525a..439799f 100644
--- 
a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/CamelSourceTestSupport.java
+++ 
b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/CamelSourceTestSupport.java
@@ -134,20 +134,4 @@ public abstract class CamelSourceTestSupport extends 
AbstractKafkaTest {
         verifyMessages(consumer);
         LOG.debug("Verified messages");
     }
-
-    /**
-     * A simple test runner that follows the steps: initialize, start 
producer, consume messages, verify results
-     *
-     * @param connectorPropertyFactory A factory for connector properties
-     * @param topic the topic to send the messages to
-     * @param count the number of messages to send
-     * @throws Exception For test-specific exceptions
-     */
-    public void runTestBlocking(ConnectorPropertyFactory 
connectorPropertyFactory, String topic, int count) throws ExecutionException, 
InterruptedException {
-        KafkaClient<String, String> kafkaClient = new 
KafkaClient<>(getKafkaService().getBootstrapServers());
-        StringMessageConsumer consumer = new 
StringMessageConsumer(kafkaClient, topic, count);
-
-        runTestBlocking(connectorPropertyFactory, consumer);
-    }
-
 }

Reply via email to