You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by lb...@apache.org on 2020/10/07 21:01:54 UTC
[camel-kafka-connector] 04/04: [core] cleanup TaskHelper
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 <lb...@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) {