This is an automated email from the ASF dual-hosted git repository. lburgazzoli pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 8dde130b9737c865c4795bfeb21958572ff3c4d8 Author: Luca Burgazzoli <lburgazz...@gmail.com> AuthorDate: Wed Oct 7 18:18:34 2020 +0200 [core] cleanup TaskHelper --- .../main/java/org/apache/camel/kafkaconnector/utils/TaskHelper.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/utils/TaskHelper.java b/core/src/main/java/org/apache/camel/kafkaconnector/utils/TaskHelper.java index 6fbeb20..78e489d 100644 --- a/core/src/main/java/org/apache/camel/kafkaconnector/utils/TaskHelper.java +++ b/core/src/main/java/org/apache/camel/kafkaconnector/utils/TaskHelper.java @@ -81,21 +81,21 @@ public final class TaskHelper { .filter(k -> k.startsWith(prefix)) .map(k -> k.replace(prefix, "") + "=" + props.get(k)) .reduce((o1, o2) -> o1 + "&" + o2) - .map(result -> (result == null || result.isEmpty()) ? "" : "?" + result) + .map(result -> result.isEmpty() ? "" : "?" + result) .orElse(""); } public static String createUrlPathFromProperties(Map<String, String> props, String prefix) { return props.keySet().stream() .filter(k -> k.startsWith(prefix)) - .map(k -> props.get(k)) + .map(props::get) .reduce((p1, p2) -> p1 + ":" + p2) .orElse(""); } public static Map<String, String> mergeProperties(Map<String, String> defaultProps, Map<String, String> loadedProps) { if (loadedProps == null && defaultProps == null) { - return Collections.EMPTY_MAP; + return Collections.emptyMap(); } else if (loadedProps == null) { return new HashMap<>(defaultProps); } else if (defaultProps == null) {