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); - } - }