Issue #561: fixed MessageMappingProcessorActorTest again after latest…

… changes Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
eclipse-ditto · Jan 21, 2020 · 7999573 · 7999573
1 parent e08dd2b
commit 7999573
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/...a/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorTest.java b/...a/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorTest.java
@@ -56,6 +56,7 @@
 import org.eclipse.ditto.model.messages.MessageHeaderDefinition;
 import org.eclipse.ditto.model.placeholders.Placeholder;
 import org.eclipse.ditto.model.placeholders.UnresolvedPlaceholderException;
+import org.eclipse.ditto.model.things.Thing;
 import org.eclipse.ditto.model.things.ThingId;
 import org.eclipse.ditto.protocoladapter.DittoProtocolAdapter;
 import org.eclipse.ditto.protocoladapter.JsonifiableAdaptable;
@@ -373,12 +374,17 @@ public void testSignalEnrichmentWithPayloadMappedTargets() {
 
             // THEN: Receive a RetrieveThing command from the facade.
             final RetrieveThing retrieveThing = expectMsgClass(RetrieveThing.class);
-            assertThat(retrieveThing.getSelectedFields()).contains(extraFields);
+            final JsonFieldSelector extraFieldsWithAdditionalCachingSelectedOnes = JsonFactory.newFieldSelectorBuilder()
+                    .addPointers(extraFields)
+                    .addFieldDefinition(Thing.JsonFields.REVISION) // additionally always select the revision
+                    .build();
+            assertThat(retrieveThing.getSelectedFields()).contains(extraFieldsWithAdditionalCachingSelectedOnes);
             assertThat(retrieveThing.getDittoHeaders().getAuthorizationContext()).containsExactly(targetAuthSubject);
             final JsonObject extra = JsonObject.newBuilder()
                     .set("/attributes/x", 5)
                     .build();
             final JsonObject extraForCachingFacade = JsonObject.newBuilder()
+                    .set("_revision", 8)
                     .setAll(extra)
                     .build();
             reply(RetrieveThingResponse.of(retrieveThing.getEntityId(), extraForCachingFacade,