Changes

Summary

1. Issue #944: Include detailMessage in `equals` and `hashCode` method of `DittoRuntimeException`. Fixed unit tests which failed because of that. (details)
2. Extracted `ShardNumberCalculator` from `ShardRegionExtractor` to make the functionality re-usable and better testable. (details)
3. [#964] add "notification" signal type. (details)
4. [#964] add SubjectExpiryNotification and annotation-based serialization. (details)
5. [#964] improve lookup time of MappingStrategies. (details)
6. [#964] add notifications to Ditto protocol; fix ShardRegionExtractorTest. (details)
7. [#964] add connection target topic for policy notifications. (details)
8. [#964] add websocket protocol messages for policy notifications. (details)
9. [#964] add "notifyBefore" to SubjectExpiry. (details)
10. [#964] fix SignalFilterTest. (details)
11. [#964] Fix unit tests. (details)
12. Make DevOpsCommandsActor abstract to allow custom extensions (details)
13. [#964] Add subject expiry notification duration to ActivateTokenIntegration. (details)
14. [#964] subscribe for policy notifications in gateway and connectivity. (details)
15. [#964] fix PoliciesServiceGlobalCommandRegistryTest and PoliciesRootActorTest. (details)
16. Fix exception response for token integration de-/activation commands with invalid subject placeholder (details)
17. #605: Add devops command to retrieve ids of all connections (details)
18. #605: Add documentation for devops command to retrieve ids of all connections (details)
19. #605: Add config value for number of entries recieved with one bd query from connection-snap collection (details)
20. #605: Fix test (details)
21. #605: fix formatting for manage connection documentation (details)
22. #605 extract connection ids retrieval into separate actor, add necessary config, add actor test, add unit for new retrieve command/response (details)
23. Revert "[#964] add "notifyBefore" to SubjectExpiry." Keep DittoDuration public. (details)
24. Add field /announce to policy subjects. (details)
25. [#964] Add "announce" field to ActivateTokenIntegration. (details)
26. add documentation for arbitrary oidc claims (details)
27. fixed escaping for used `{{` syntax (details)
28. [#964] Rename Notification to Announcement. Rename SubjectExpiryNotification to SubjectDeletionAnnouncement. (details)
29. [#964] Fix DittoProtocolAdapterTest. (details)
30. Provide possibility to send generic JSON streams as chunked HTTP entities (WIP). (details)
31. [#964] review: (details)
32. [#964] round up SubjectAnnouncement in ActivateTokenIntegrationStrategy; add policyAnnouncementPub to PolicyPersistenceActor; fix DittoProtocolAdapterTest. (details)
33. [#964] Fix ActivateTokenIntegrationStrategy. (details)
34. #605: Fix documentation (details)
35. Adjusted dependency to akka-serialization-jackson in bom and adjusted some tests. (details)
36. Added unit test to ensure that serialization of `JsonValueSourceRef` works as expected (WIP). (details)
37. Add jackson serialization annotations for JsonValueSourceRef (details)
38. [#964] publish policy announcement before expiry. (details)
39. Added @JsonCreator to static factory method of `JsonValueSourceRef`. This way deserialization calls the static factory which is the preferred way of object creation. Furthermore the name of the sourceRef instance field does not have to be hard-coded as String. (details)
40. Added unit test for checking that serialization with jackson-cbor works for `JsonValueSourceRef`. (details)
41. [#964] announce subjects when deleted. (details)
42. add documentation for MongoDB requirements when using a MongoDB service; (details)
43. Change CboRJsonValueSerializer config default to constants (details)
44. Review: Fix anchor link. (details)
45. Update README.md (details)
46. [#964] first step of always keeping policy persistence actors using annoucements alive: (details)
47. [#964] generalized "reconnecting behavior" of former "ReconnectActor" for connectivity to "PersistencePingActor" (details)
48. [#964] fixed MappingStrategiesBuilderTest (details)
49. [#964] Configure subject-announcement via the body of HTTP requests for the policy action activateTokenIntegration; improve openapi and javadoc. (details)
50. Formatting health command (details)
51. [#964] persist EmptyEvent handled in AbstractShardedPersistenceActor in order to get a journal entry with the "always-alive" journal tag for all connections which should be "open" (details)
52. [#964] moved EmptyEvent class to upper level because of global event registry tests (details)
53. [#964] do not drop policy notifications in websocket and connectivity. (details)
54. adjusted/fixed some license declaration stuff in created jars (details)
55. [#964] review: changed HTTP request payload of `activateTokenIntegration` POST endpoint to be wrapped in an "annoucement" JsonObject (details)
56. [#964] review: pass through DittoHeaders for SubjectDeletion notification when available, build a new correlation-id if not (details)
57. [#964] adjusted that an "internal server error" 500 was returned when top-level policy actions could not be applied (details)
58. Do not add header mappings for MQTT connections (details)
59. Create an empty header mapping for new connections (details)
60. Use content-type in ditto protocol message to describe the content type of (details)
61. [#964] persistence actors: always schedule activity check; decide "always-alive" flag and journal tag at the same time; remove "always-alive" tag setting from command strategies; test policy journal tags. (details)
62. [#964] fix PolicyPersistenceActorTest. (details)
63. Adapt documentation and set content type only if event contains payload (details)
64. [#964] enhanced ExpressionResolver#resolvePartially in a way to specify an optional list of placeholder prefixes which are not allowed to be left unresolved (details)
65. make headerMapping of source non-nullable (details)
66. Apply mqtt mappings additionally to the configure header mappings (details)
67. [#964] Add an index on journal collections for PersistencePingActor. (details)
68. [#964] add comment; rename test methods; always persist empty event for open connections on ping with empty journal tag. (details)
69. Add nightly build for docker images (details)
70. [#964] added documentation about announcements in general and the specifically added "subjectDeletion" announcement (details)
71. post merge: add missing dependency to pom.xml (details)
72. [#964] send past-due announcements for new subjects post modification. (details)
73. [#964] added "subjectDeletion" announcement protocol example to sitemap (details)
74. Adapt dockerfile-release to download artifact from another URL (details)
75. [#964] review: renamed "deletedAt" to "deleteAt" of subject deletion announcements (details)
76. [#964] Move 'onEntityModified' after all other event persistence callbacks; fix persistence actor test config. (details)
77. #985: Add model for ssh tunnel (details)
78. put Maven repo url in double quotes (details)
79. #985: Fix test error (details)
80. #985: Formatting (details)
81. update to latest Akka dependencies (details)
82. #985: Add test for new credential types (details)
83. review: fixed dead links in Ditto documentation (details)
84. Move decoding of username and password to connection model (details)
85. Fix error description for Message sending errors (details)
86. remove no longer valid comment (details)
87. Add test for policy revision update in search index; fix timer duplication. (details)
88. Add blog post for Azure IoT Hub integration (details)
89. removed explicit akka-serialization-jackson dependency (details)
90. ThingUpdater: Force cache reload when requested to update thing. (details)
91. Add SonarQube stage in multibranch for feature branch scans (details)
92. update 3rd-party documents preparing Ditto 2.0 release (details)
93. add swagger documentation for new Patch methods; (details)
94. add new section in README.md; (details)
95. review: added "PatchValue" to api-2-index.yml in order to fix broken references in generated ditto-api-2.yml (details)
96. [WIP] do not report status warning after successful sync. (details)
97. review: adjust just minor formatting (details)
98. review: fixed test by fixing BackgroundSyncActor.getMostSevereLevelFromEvents - the most severe level was not preserved when it was caused by a "StreamTerminated" event (details)
99. fixed javadoc error (details)
100. Parse the criteria before validating it. This ensures that (details)
101. added command for resetting the events of AbstractBackgroundStreamingActorWithConfigWithStatusReport (details)
102. fixed javadoc error (details)
103. Fix review findings for Azure IoT Hub integration blog post (details)
104. add ThingErrorResponseAdapterTest; (details)
105. #985 Add support to establish a connection via an ssh tunnel. Ssh tunnel management is done in new SshTunnelActor. The tunnel is controlled (open/close) with the existing state machine in BaseClientActor. Add connecting via tunnel for existing protocols (except Kafka, which requires multiple connections to bottstrap server and zookeeper). (details)
106. #985: Fix extraction of known hosts (details)
107. Introduce ConnectionUnauthorizedException which is issued for invalid (details)
108. add new SearchAction error; (details)
109. add license header to new test; (details)
110. add since annotation; (details)
111. add parameter to skip sonarqube scan during pipeline run; (details)
112. if when expression to skip sonarqube scan; (details)
113. #985 fix handling of error on initial mqtt connection, establish ssh tunnel when testing a connection (details)
114. Validate extra field selection for connection targets (details)
115. Validate selected fields of a thing for websocket sessions as well (details)
116. More fixes to the azure-iot-hub-integration blog-post (details)
117. renamed MergeToggle to generic FeatureToggle in order to be able to place additional (details)
118. Add link to azure-iot-hub-device-simulator example to blogpost (details)
119. Replaced `DittoThingSnapshotTaken` with `ThingSnapshotTaken`. (details)
120. fix some typos for ThingSnapshotTaken (details)
121. Made method for creating group topic public. (details)
122. review: fixed @Nullable warnings and handling of null values in AmqpClientActor and surroundings (details)
123. #985 review addition of ssh tunnel to connection model, add username to ssh public key credentials (details)
124. #985 apply public key credentials for ssh tunnel (details)
125. review: added missing javadocs (details)
126. #985 simplify fingerprint verification (details)
127. Change publishing date for Azure IoT Hub blogpost (details)
128. Support for building arm64 ditto snapshot images (details)
129. fixed bug that iterator in EventSnapshotCleanupCoordinator was not cleaned up (details)
130. Fix placeholder encoding for blogpost (details)
131. #985 fix loading of public key and move context information for parsing errors to ExceptionMapper (details)
132. fixing a potential NPE in ThingPredicatePredicateVisitor (details)
133. fixed "in" predicate comparing numbers, use comparator instead of equality (details)
134. #985 fix KafkaClientActorTest (details)
135. add test case for visitIn method; (details)
136. #985 add validation of ssh tunnel configuration (details)
137. #985 add javadoc, more logging (details)
138. #985 set supported client side user auth method (details)
139. #985 set exclusive public key/password identity on ssh session (no default fallbacks) (details)
140. #985 rename SshPublicKeyCredentials (details)
141. #985 use default mqtt connect and socket timeout (details)
142. #985 limit supported ssh client authentication methods globally (details)
143. #985 provide exception class name if exception message is null in connectivity error responses (details)
144. #985 add some javadoc, remove TODO (details)
145. #985 document ssh tunneling feature (details)
146. #985 move tunneling doc to separate section and refer to it from basic section (details)
147. extend ConnectivityConfigProvider to get connectivity config via dittoHeaders; (details)
148. #985 reject ssh tunneling for kafka connections (details)
149. #985 add reference to SSH RFC and hint about possible performance impact of using ssh tunneling (details)
150. #985 fix message format of connection logs (details)
151. fix failing ConnectionValidatorTest; (details)
152. #985 add comment (details)
153. applied sharding on the "key" of Ditto "ddata" / pub/sub extension (details)
154. fixed that connection-id MDC entry was lost in InboundDispatchingActor (details)
155. fixed immutability test of DefaultDistributedDataConfig (details)
156. improved exception logging in InboundDispatchingActor (details)
157. handle ThingMergeEvents in NormalizedMessageMapper; (details)
158. Update javadoc (details)
159. Update javadoc (details)
160. #985 add missing javadoc, remove debug log statements (details)
161. #985 add missing javadoc (details)
162. always use 'application/json' as content-type for NormalizedMessageMapper; (details)
163. Prioritize very active connections over inactive connections for reconnecting (details)
164. Enable throttling of persistence ping actor also for tag sorted stream (details)
165. Fix formatting of blogpost (details)
166. Set content type in message headers instead of _context headers (details)
167. fix unit tests of normalized message mapper test (details)
168. #985 minor documentation fixes (details)
169. #985 improve exception message if tunnel actor is started without required configuration, restart tunnel actor in case of an unexpected failure (details)
170. #985 also validate ssh host, extract HostValidator interface to improve testability (details)
171. #985 add note about security considerations when using ssh tunneling (details)
172. Make sure to use numeric ordering for tag order (details)
173. #985 Fix copyright header (details)
174. #985 Add blog post for SSH tunnel for managed connections (details)
175. Remove aggregation of connection priority providers from ConnectionPriorityProvider (details)
176. #985 Add @since tag (details)
177. Make priority of priority provider non optional (details)
178. #985 Add blog findings (details)
179. Fix unittests (details)
180. Make priority update interval fuzzy to avoid that all connections (details)
181. expand authors.yml (details)
182. Log the correct key for update and get response handling errors (details)
183. review: (details)
184. Fix typo (details)
185. Improves the priority ordering in MongoReadJournal (details)
186. review: (details)
187. updated readme to include trademark symbol (details)
188. added trademark signs in website/docs (details)

Issue #944: Include detailMessage in `equals` and `hashCode` method of `DittoRuntimeException`. Fixed unit tests which failed because of that.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>

Extracted `ShardNumberCalculator` from `ShardRegionExtractor` to make the functionality re-usable and better testable.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>

[#964] add "notification" signal type.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

[#964] add SubjectExpiryNotification and annotation-based serialization.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

[#964] improve lookup time of MappingStrategies.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

[#964] add notifications to Ditto protocol; fix ShardRegionExtractorTest.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

[#964] add connection target topic for policy notifications.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

[#964] add websocket protocol messages for policy notifications.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

[#964] add "notifyBefore" to SubjectExpiry.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

[#964] fix SignalFilterTest.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

[#964] Fix unit tests.

Changes:
	modified:   model/base/src/test/java/org/eclipse/ditto/model/base/headers/DittoDurationTest.java
	modified:   model/base/src/test/java/org/eclipse/ditto/model/base/headers/DittoDurationValueValidatorTest.java
	modified:   model/base/src/test/java/org/eclipse/ditto/model/base/headers/TimeoutValueValidatorTest.java

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

Make DevOpsCommandsActor abstract to allow custom extensions

Signed-off-by: David Schwilk <david.schwilk@bosch.io>

[#964] Add subject expiry notification duration to ActivateTokenIntegration.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

[#964] subscribe for policy notifications in gateway and connectivity.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

[#964] fix PoliciesServiceGlobalCommandRegistryTest and PoliciesRootActorTest.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

Fix exception response for token integration de-/activation commands with invalid subject placeholder

Signed-off-by: David Schwilk <david.schwilk@bosch.io>

#605: Add devops command to retrieve ids of all connections

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>

#605: Add documentation for devops command to retrieve ids of all connections

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>

#605: Add config value for number of entries recieved with one bd query from connection-snap collection

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>

#605: Fix test

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>

#605: fix formatting for manage connection documentation

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>

#605 extract connection ids retrieval into separate actor, add necessary config, add actor test, add unit for new retrieve command/response

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>

Revert "[#964] add "notifyBefore" to SubjectExpiry." Keep DittoDuration public.

This partially reverts commit 7c86a7297cf0a1544925634ac19fe9659ce985a8.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

Add field /announce to policy subjects.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

[#964] Add "announce" field to ActivateTokenIntegration.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

add documentation for arbitrary oidc claims

Signed-off-by: Dirk Van Haerenborgh <dirk.vanhaerenborgh@aloxy.io>

document behaviour for unresolvable placeholders

Signed-off-by: Dirk Van Haerenborgh <dirk.vanhaerenborgh@aloxy.io>

Update documentation/src/main/resources/pages/ditto/installation-operating.md

Co-authored-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>

Update documentation/src/main/resources/pages/ditto/installation-operating.md

Co-authored-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>

add migration notes

Signed-off-by: Dirk Van Haerenborgh <dirk.vanhaerenborgh@aloxy.io>

fixed escaping for used `{{` syntax

[#964] Rename Notification to Announcement. Rename SubjectExpiryNotification to SubjectDeletionAnnouncement.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

[#964] Fix DittoProtocolAdapterTest.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

Provide possibility to send generic JSON streams as chunked HTTP entities (WIP).
* Unified DittoDevOpsCommandActor with DevOpsCommandActor as there won't be further sub-classes.
* Added custom serializer in order to send `JsonValue` throughout the Akka cluster.
* Added custom message that wraps a SourceRef of JsonValues.
* Added Akka Jackson serializer in order to serialize custom SourceRef-wrapping message.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>

[#964] review:
* moved now public DittoDuration from "headers" to "common" package
* made `subjectAnnouncement` in `Subject` nullable
* removed `emty()` `SubjectAnnouncement` specifics
* renamed JSON field `announce` to noun `announcement`
* fixed OSGi imports/exports in new announcement poms
* moved JsonFieldDefinition to separate JsonFields subclasses in interfaces
* made `SubjectDeletionAnnoucement.subjectIds` a Set
* added some missing `@since` javadoc tags

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>

[#964] round up SubjectAnnouncement in ActivateTokenIntegrationStrategy; add policyAnnouncementPub to PolicyPersistenceActor; fix DittoProtocolAdapterTest.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

[#964] Fix ActivateTokenIntegrationStrategy.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

#605: Fix documentation

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>

Adjusted dependency to akka-serialization-jackson in bom and adjusted some tests.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>

Added unit test to ensure that serialization of `JsonValueSourceRef` works as expected (WIP).

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>

Add jackson serialization annotations for JsonValueSourceRef

Signed-off-by: David Schwilk <david.schwilk@bosch.io>

[#964] publish policy announcement before expiry.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

Added @JsonCreator to static factory method of `JsonValueSourceRef`. This way deserialization calls the static factory which is the preferred way of object creation. Furthermore the name of the sourceRef instance field does not have to be hard-coded as String.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>

Added unit test for checking that serialization with jackson-cbor works for `JsonValueSourceRef`.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>

[#964] announce subjects when deleted.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

add documentation for MongoDB requirements when using a MongoDB service;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>

Change CboRJsonValueSerializer config default to constants

Signed-off-by: David Schwilk <david.schwilk@bosch.io>

Review: Fix anchor link.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

Update README.md

fixed path to directory to copy k3s.yaml file

[#964] first step of always keeping policy persistence actors using annoucements alive:
* created a new MongoReadJournal functionality which finds out persistence IDs based on a provided journal "tag"
* pass through "journal-tags" as internal DittoHeaders in order to append them to the event journal persistence
* consequently use AbstractMongoEventAdapter as base for all EventAdapters and consolidated duplicated functionality
* fixed some generics magic
* provide "performToJournalMigration" and "performFromJournalMigration" as common way for EventAdapters to migrate data to/from persistence
* introduced "always-alive" tag and don't stop persistenceActors which get journal entries with this tag
* apply for PolicyCommmandStrategies that "always-alive" tag is set one SubjectAnnoucements are used

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>

[#964] generalized "reconnecting behavior" of former "ReconnectActor" for connectivity to "PersistencePingActor"
* moved to "ditto-services-utils-persistentactors" module
* re-use in both connectivity + policies in order to ping/wake up certain actors after cold start of the cluster (and also to keep alive)
* added PingCommand and PingCommandResponse message which can be sent to sharded actors in the cluster
* on cleanup of persistenceActors, always keep 1 last journal entry (which may be tagged by e.g. "always-alive") in order to find out which actors to ping
* don't stop PersistenceActors which are marked as "alwaysAlive" (e.g. via the journal tag) on activity check

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>

[#964] fixed MappingStrategiesBuilderTest

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>

[#964] Configure subject-announcement via the body of HTTP requests for the policy action activateTokenIntegration; improve openapi and javadoc.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

Formatting health command

[#964] persist EmptyEvent handled in AbstractShardedPersistenceActor in order to get a journal entry with the "always-alive" journal tag for all connections which should be "open"
* produce this EmptyEvent when a ConnectionPersistenceActor was pinged with "empty" tag - this provides a migration path in order to only restore connections with target state "open" in the future

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>

[#964] moved EmptyEvent class to upper level because of global event registry tests
* there the import to EmptyEvent was added for things;policies;connectivity

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>

[#964] do not drop policy notifications in websocket and connectivity.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

adjusted/fixed some license declaration stuff in created jars

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>

[#964] review: changed HTTP request payload of `activateTokenIntegration` POST endpoint to be wrapped in an "annoucement" JsonObject
* fixed swagger documentation which had some dead references

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>

[#964] review: pass through DittoHeaders for SubjectDeletion notification when available, build a new correlation-id if not

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>

[#964] adjusted that an "internal server error" 500 was returned when top-level policy actions could not be applied

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>

Do not add header mappings for MQTT connections

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>

Create an empty header mapping for new connections

* This is done to avoid having the migration applied to new connections.
  Otherwise it would not be possible to have no header-mapping configured

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>

Use content-type in ditto protocol message to describe the content type of
the value of a ditto protocol message.

* For most usages of ditto-protocol content type in the protocol adapter,
  application/json should have been used.

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>

[#964] persistence actors: always schedule activity check; decide "always-alive" flag and journal tag at the same time; remove "always-alive" tag setting from command strategies; test policy journal tags.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

[#964] fix PolicyPersistenceActorTest.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>

Adapt documentation and set content type only if event contains payload

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>

[#964] enhanced ExpressionResolver#resolvePartially in a way to specify an optional list of placeholder prefixes which are not allowed to be left unresolved
* handle resulting UnresolvedPlaceholderException in routes by creating a PolicyActionFailedException

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>

make headerMapping of source non-nullable

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>

Apply mqtt mappings additionally to the configure header mappings

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>

[#964] Add an index on journal collections for PersistencePingActor.

Add the compound index on _tg, pid so that PersistencePingActor
need not sort all results.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>