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 2984a528bdf72bd895d1663a47dbb7d0a07ebe63 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Wed Feb 24 11:41:47 2021 +0100 Avoid type specification on constructors when possible --- .../camel/kafkaconnector/maven/docs/UpdateDocComponentsListMojo.java | 2 +- .../camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/tooling/camel-kafka-connector-docs-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/docs/UpdateDocComponentsListMojo.java b/tooling/camel-kafka-connector-docs-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/docs/UpdateDocComponentsListMojo.java index 2ca59b6..579764c 100644 --- a/tooling/camel-kafka-connector-docs-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/docs/UpdateDocComponentsListMojo.java +++ b/tooling/camel-kafka-connector-docs-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/docs/UpdateDocComponentsListMojo.java @@ -113,7 +113,7 @@ public class UpdateDocComponentsListMojo extends AbstractMojo { protected void executeComponentsReadme() throws MojoExecutionException, MojoFailureException { CamelKafkaConnectorTableModel tableModel = new CamelKafkaConnectorTableModel(); - ArrayList<CamelKafkaConnectorTableOptionModel> options = new ArrayList<CamelKafkaConnectorTableOptionModel>(); + ArrayList<CamelKafkaConnectorTableOptionModel> options = new ArrayList<>(); if (connectorsDir != null && connectorsDir.isDirectory()) { File[] files = connectorsDir.listFiles(); diff --git a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java index 5f2b536..6ae3e1a 100644 --- a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java +++ b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java @@ -437,7 +437,7 @@ public class CamelKafkaConnectorUpdateMojo extends AbstractCamelKafkaConnectorMo throw new UnsupportedOperationException("Connector type not supported: " + ct + " must be one of " + ConnectorType.SINK + ", " + ConnectorType.SOURCE); } - List<CamelKafkaConnectorOptionModel> listOptions = new ArrayList<CamelKafkaConnectorOptionModel>(); + List<CamelKafkaConnectorOptionModel> listOptions = new ArrayList<>(); model.getEndpointPathOptions().stream().filter(filterEndpointOptions) .forEachOrdered(epo -> addConnectorOptions(sanitizedName, ct, javaClassConnectorConfig, confMethod, "PATH", ctLowercaseName, "path", epo, listOptions)); model.getEndpointParameterOptions().stream().filter(filterEndpointOptions)
