This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch catalog-impr in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit a2447df9ccfa04b5f74f63019e279745479c6775 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Thu Oct 22 09:27:33 2020 +0200 Fixed CS --- .../catalog/CamelKafkaConnectorCatalog.java | 17 ++++++++--------- 1 file changed, 8 insertions(+), 9 deletions(-) diff --git a/camel-kafka-connector-catalog/src/main/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java b/camel-kafka-connector-catalog/src/main/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java index 94f23ea..7009c58 100644 --- a/camel-kafka-connector-catalog/src/main/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java +++ b/camel-kafka-connector-catalog/src/main/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java @@ -151,15 +151,14 @@ public class CamelKafkaConnectorCatalog { } public CamelKafkaConnectorOptionModel getOptionModel(String connectorName, String optionName) { - List<CamelKafkaConnectorOptionModel> options = getConnectorsModel().get(connectorName).getOptions(); - for (Iterator iterator = options.iterator(); iterator.hasNext();) { - CamelKafkaConnectorOptionModel camelKafkaConnectorOptionModel = (CamelKafkaConnectorOptionModel) iterator - .next(); - if (camelKafkaConnectorOptionModel.getName().equals(optionName)) { - return camelKafkaConnectorOptionModel; - } - } - return null; + List<CamelKafkaConnectorOptionModel> options = getConnectorsModel().get(connectorName).getOptions(); + for (Iterator iterator = options.iterator(); iterator.hasNext();) { + CamelKafkaConnectorOptionModel camelKafkaConnectorOptionModel = (CamelKafkaConnectorOptionModel)iterator.next(); + if (camelKafkaConnectorOptionModel.getName().equals(optionName)) { + return camelKafkaConnectorOptionModel; + } + } + return null; } /**