[camel-kafka-connector] 08/14: Force the embedded runner to throw an exception if the provided service is null

[or...@apache.org]

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

commit e52aba2c556d418e46d9af078a7dd5fe6c1183d3
Author: Otavio Rodolfo Piske <op...@redhat.com>
AuthorDate: Wed Jan 13 15:16:38 2021 +0100

    Force the embedded runner to throw an exception if the provided service is null
---
 .../common/services/kafkaconnect/KafkaConnectRunnerService.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectRunnerService.java b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectRunnerService.java
index 8fadc26..c895490 100644
--- a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectRunnerService.java
+++ b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectRunnerService.java
@@ -41,7 +41,7 @@ public class KafkaConnectRunnerService implements KafkaConnectService {
 
 
     public KafkaConnectRunnerService(KafkaService kafkaService) {
-        Objects.nonNull(kafkaService);
+        Objects.requireNonNull(kafkaService);
 
         LOG.debug("Connecting the Kafka Connect Runner to {}", kafkaService.getBootstrapServers());
         this.kafkaConnectRunner = new KafkaConnectRunner(kafkaService.getBootstrapServers());