fix that placeholder time:now did not resolve to the current time w…

…hen used in a connection's headerMapping Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
eclipse-ditto · Jan 24, 2022 · d3de1e8 · d3de1e8
1 parent 93b816c
commit d3de1e8
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/...c/main/java/org/eclipse/ditto/connectivity/api/placeholders/ConnectivityPlaceholders.java b/...c/main/java/org/eclipse/ditto/connectivity/api/placeholders/ConnectivityPlaceholders.java
@@ -74,7 +74,7 @@ public static ResourcePlaceholder newResourcePlaceholder() {
     /**
      * @return the singleton instance of {@link TimePlaceholder}
      */
-    public static TimePlaceholder newMiscPlaceholder() {
+    public static TimePlaceholder newTimePlaceholder() {
         return TimePlaceholder.getInstance();
     }
 

diff --git a/...ity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/Resolvers.java b/...ity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/Resolvers.java
@@ -65,7 +65,7 @@ private Resolvers() {
             }),
             ResolverCreator.of(ConnectivityPlaceholders.newTopicPathPlaceholder(), (e, s, t, a, c) -> t),
             ResolverCreator.of(ConnectivityPlaceholders.newResourcePlaceholder(), (e, s, t, a, c) -> s),
-            ResolverCreator.of(ConnectivityPlaceholders.newMiscPlaceholder(), (e, s, t, a, c) -> null),
+            ResolverCreator.of(ConnectivityPlaceholders.newTimePlaceholder(), (e, s, t, a, c) -> new Object()),
             ResolverCreator.of(ConnectivityPlaceholders.newRequestPlaceholder(), (e, s, t, a, c) -> a),
             ResolverCreator.of(ConnectivityPlaceholders.newConnectionIdPlaceholder(), (e, s, t, a, c) -> c)
     );

diff --git a/...ain/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPushValidator.java b/...ain/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPushValidator.java
@@ -107,7 +107,7 @@ protected void validateTarget(final Target target, final DittoHeaders dittoHeade
                 ConnectivityPlaceholders.newThingPlaceholder(),
                 ConnectivityPlaceholders.newTopicPathPlaceholder(),
                 ConnectivityPlaceholders.newResourcePlaceholder(),
-                ConnectivityPlaceholders.newMiscPlaceholder(),
+                ConnectivityPlaceholders.newTimePlaceholder(),
                 newHeadersPlaceholder(),
                 ConnectivityPlaceholders.newFeaturePlaceholder());
         validateTargetAddress(target.getAddress(), dittoHeaders, targetDescription);

diff --git a/...ain/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/AbstractMqttValidator.java b/...ain/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/AbstractMqttValidator.java
@@ -14,11 +14,11 @@
 
 import static org.eclipse.ditto.connectivity.api.placeholders.ConnectivityPlaceholders.newEntityPlaceholder;
 import static org.eclipse.ditto.connectivity.api.placeholders.ConnectivityPlaceholders.newFeaturePlaceholder;
-import static org.eclipse.ditto.connectivity.api.placeholders.ConnectivityPlaceholders.newMiscPlaceholder;
 import static org.eclipse.ditto.connectivity.api.placeholders.ConnectivityPlaceholders.newPolicyPlaceholder;
 import static org.eclipse.ditto.connectivity.api.placeholders.ConnectivityPlaceholders.newResourcePlaceholder;
 import static org.eclipse.ditto.connectivity.api.placeholders.ConnectivityPlaceholders.newSourceAddressPlaceholder;
 import static org.eclipse.ditto.connectivity.api.placeholders.ConnectivityPlaceholders.newThingPlaceholder;
+import static org.eclipse.ditto.connectivity.api.placeholders.ConnectivityPlaceholders.newTimePlaceholder;
 import static org.eclipse.ditto.connectivity.api.placeholders.ConnectivityPlaceholders.newTopicPathPlaceholder;
 import static org.eclipse.ditto.placeholders.PlaceholderFactory.newHeadersPlaceholder;
 
@@ -115,7 +115,7 @@ protected void validateTarget(final Target target, final DittoHeaders dittoHeade
 
         validateTargetQoS(qos.get(), dittoHeaders, targetDescription);
         validateTemplate(target.getAddress(), dittoHeaders, newThingPlaceholder(), newTopicPathPlaceholder(),
-                newResourcePlaceholder(), newMiscPlaceholder(), newHeadersPlaceholder(), newFeaturePlaceholder());
+                newResourcePlaceholder(), newTimePlaceholder(), newHeadersPlaceholder(), newFeaturePlaceholder());
     }
 
     /**