Changes

Summary

  1. Issue #773: `ThingCommandEnforcement` now uses its own `DittoLogger` instead of the `DittoDiagnosticLoggingAdapter` of its parent. (details)
  2. Issue #773: Got rid of unnecessary `Optional`s within `ThingCommandEnforcement` to reduce complexity of the class and thus improve understandability. (details)
  3. Issue #773: Use DittoLogger to set correlation ID in `PreEnforcer`. (details)
  4. Issue #773: Renamed variables and parameters to make code easier to understand. (details)
  5. Issue #773: Introduced `ThreadSafeDittoLogger` type and an immutable implementation thereof. (details)
  6. Issue #773: Added "mixin" interface `WithMdcEntry` to allow the setting of arbitrary MDC values to a logger. (details)
  7. Issue #773: Use `ThreadSafeDittoLogger` in `ThingCommandEnforcement` and `MessageMappingProcessorActor`. (details)
  8. Issue #773: Allow to set arbitrary context values to `DittoLogger` and some refactorings: (details)
  9. Issue #773: Allow to set arbitrary context values to `DittoDiagnosticLoggingAdapter` and added unit tests. (details)
  10. Issue #773: Removed superfluous method delegations from direct sub-classes of `AbstractDiagnostincLoggingAdapter`. (details)
  11. Issue #773: Introduced `ThreadSafeDittoDiagnosticLoggingAdapter` as well as an immutable implementation thereof. (details)
  12. Issue #773: Made `ThreadSafeDittoDiagnosticLoggingAdapter` a `LoggingAdapter` instead of a `DiagnosticLoggingAdapter` as setting the MDC directly would make immutable implementation impossible. Renamed the classes accordingly. Simplified `ImmutableDittoLoggingAdapter`. (details)
  13. Issue #773: Renamed `ImmutableThreadSafeDittoLogger` to `ImmutableDittoLogger` to remove redundancy in class name. (details)
  14. Issue #792: add scaffold for another DData for uniqueness constraint on ack labels; minor improvements. (details)
  15. Issue #792: Add a distributed data without lossy compression for uniqueness constraint. (details)
  16. Issue #792: Bootstrap AcksUpdater; remove terminated subscribers from DData. (details)
  17. Issue #792: AcksUpdater: detect local losers of race conditions. (details)
  18. Issue #792: remove SubUpdater dependency from AcksUpdater. (details)
  19. Issue #792: allow ack label declarations at DistributedSub. (details)
  20. Issue #773: Manually merged test cases from master branch. (details)
  21. Issue #792: pubsub: extract ClusterMemberRemovedAware mixin; add seqNr to SubAck so that they are not sent out prematurely. (details)
  22. Issue #792: move AcknowledgementLabelNotUniqueException to ditto.signal.acks.base. (details)
  23. Issue #773: Create a copy of MDC when getting MDC from DiagnosticLoggingAdapter as it returns an immutable map. This differs from the actual documentation of Akka and caused exceptions. (details)
  24. Issue #773: Use `ThreadSafeDittoLogger` for logging and some refactoring: (details)
  25. Issue #773: Removed dedicated methods for setting and discarding correlation ID from `AbstractDiagnosticLoggingAdapter` as the more generic method 'putMdcEntry' can be used instead. (details)
  26. Issue #773: Only make copy of MDC if is going to be changed. (details)
  27. Issue #773: Use `ThreadSafeDittoLoggingAdapter` for logging in `BasePublisherActor` and `BaseClientActor` as well as in their sub-classes. (details)
  28. Issue #773: Fixed unit test. (details)
  29. Issue #773: Fixed unit tests. (details)
  30. Issue #773: Fixed more unit tests. (details)
  31. Issue #773: Fixed even more unit tests. (details)
  32. Issue #773: review: scaladoc styleguide fixes (details)
  33. Fix a concurrency issue in AcksUpdater. (details)
  34. Issue #792: stop using localSubscriptionsChanged in AcksUpdater; add tests for race conditions; fix remote conflict test. (details)
  35. Issue #773: fixed unit tests by fixing mocking of loggers (details)
  36. Issue #792: simplify AcksUpdater; update documentation and test. (details)
  37. Issue #792: make authentication non-blocking; update TODOs; make query parameters accessible to WebsocketRoute. (details)
  38. Issue #773: Fixed compilation error: implementations have to use immutable Seq. (details)
  39. Issue #792: Make ack label declaration optional in PubSubFactory; disconnect websocket on AcknowledgementLabelNotUniqueException. (details)
  40. Issue #792: fix StreamingSessionActorHeaderInteractionTest; remove unused fields; fix compile errors. (details)
  41. Issue #792: relax ack label regex. (details)
  42. review of declared acks in pubsub (details)
  43. added correlation-id when "retrievePartialThing" / enriching outbound signals in MessageMappingProcessorActor (details)
  44. fixed adding correlation-id for "RetrieveThing" commands caused by enrichment (details)
  45. Fixing dependecies (details)
  46. Add implementation for ConnectionPlaceholder to resolve the ID (details)
  47. Issue #773: Post-merger adjustments: (details)
  48. Issue #792: Make -AutthorizationEnforcer asynchronous for Websocket and SSE. (details)
  49. Issue #792: stop testing DummyQueryCommand. (details)
  50. Issue #792: Add "declaredAcks" to connection sources. (details)
  51. Issue #792: validate that issued and declared acks of connections are prefixed with the connection ID. (details)
  52. Issue #792: maintain "ackLabelDeclared" flag in ConnectionPersistenceActor. (details)
  53. Issue #792: test connection ack label declaration; fix tests. (details)
  54. Issue #792: deny acknowledgements from WS and connections unless declared. (details)
  55. Issue #792: ensure Ack.LabelNotDeclaredException gets published to reply targets; discriminate incoming acknowledgements by their source. (details)
  56. Issue #792: fix MessageMappingProcessorActorHeaderInteractionTest; test StreamingSessionActor's acknowledgement handling. (details)
  57. Issue #792: Test that WS streams complete when StreamingSessionActor stops. (details)
  58. Use ConnectionIdPlaceholder in Resolvers (details)
  59. Resolve connection ID placeholder in declared and issued acks (details)
  60. Review of declaration of acks for websocket connections (details)
  61. Issue #773: Post-merger adjustments: Fixed compilation errors. (details)
  62. added metric about acknowledgements (whether they were a success and redeliver status) (details)
  63. Do not resolve connection ID placeholder in source and target acknowledgements (details)
  64. Issue #792: GlobalCommandRegistryTestCases: exclude Dummy* commands instead of private classes. (details)
  65. Issue #792: Fix review findings and StreamingSessionActorTest. (details)
  66. Handle case of empty acknowledgements list inside declareAcknowledgements (details)
  67. Split MessageMappingProcessor into Inbound- and OutboundMappingProcessor (details)
  68. Issue #773: Not-thread-safe loggers and logging adapters handle ConcurrentModificationException for cases when they are used by multiple threads. (details)
  69. Issue #773: Directives are simultaneously executed by multiple threads, thus thread-safe logger has to be used. (details)
  70. Separate inbound and outbound MessageMappingProcessorActors (details)
  71. Issue #773: Logger of `WebSocketRoute` is simultaneously called by multiple threads, thus thread-safe logger is used. (details)
  72. fix unit tests (details)
  73. added 1.3 as new docVersion (details)
  74. increased binary-compatibility-check version to released 1.3.0 (details)
  75. Issue #773: Set version of `@since` tags to upcoming Ditto release 1.4.0. (details)
  76. restructure documentation to bring default header values closer to their interaction description (details)
  77. Issue #792: test target-issued acks handling by connection persistence actor and fix it. (details)
  78. Do allow live message responses without enforcing technical acknowledgement (details)
  79. Consider target ack to be requested if target ack is live-response (details)
  80. Add implicit acknowledgement only if requested-acks is non-empty (details)
  81. consider a live response with a non timeout status code to be successful (details)
  82. fixed that search via SSE was broken (details)
  83. decouple response-required default value from requested acks (details)
  84. Adjust documentation for header interaction between requested-acks (details)
  85. Adjust documentation regarding the default value of response-required (details)
  86. review: fixed javadoc errors (details)
  87. Fixes javadoc and removes telling the exception to a sender (details)
  88. Issue #792: adjusted since javadoc annotations to 1.4.0 (details)
  89. Issue #792: removed "declared-acks" from DittoHeaderDefinition and DittoHeaders again (details)
  90. Issue #792: re-added "declared-acks" to DittoHeaderDefinition, but keep removed from DittoHeaders (details)
  91. Issue #792: log and respond with errors when subscribing to Ditto pubsub (details)
  92. Issue #792: post merge commit after merge from master (details)
  93. Issue #792: used ConnectivityInternalErrorException instead of Gateway one for ConnectionPersistenceActor (details)
  94. fixed long open TODO: made ConnectivityStatus Jsonifiable (details)
  95. Issue #792: terminated session actor after subscribe to Ditto pubsub failed (details)
  96. slight improvement on the wording in the policy base documentation (details)
  97. Issue #773: Handle ConcurrentModificationException at all places where it could be thrown to avoid disturbing actual service processes. (details)
  98. Issue #773: Use string for removal. (details)
  99. Adds blog post about the acknowledgement feature (details)
  100. Issue #773: Javadoc of java.util.Map does not fully reveal where ConcurrentModificationExceptions are thrown, thus catching the exception for all interactions with 'localMdc' map. (details)
  101. relax acknowledgement label regex (details)
  102. fix unit tests (details)
  103. replace since 1.3.0 with 1.4.0 for newly introduced AcknowledgementLabelNotUniqueException (details)
  104. completed javadoc todos (details)
  105. Add blog post about async client creation; update email of authors. (details)
  106. Update java client documentation. (details)
  107. Issue #792: review of e2e-acknowledgement blogpost: (details)
  108. Fixed Mapping timers (details)
  109. log warning on expiration of mapping timer (details)
  110. Validate connection ID (details)
  111. adapt json example to described use case (details)
  112. Issue #792: relaxed AcknowledgementLabel regex to be able to start with a placeholder (details)
  113. Issue #792: concretize message mapping outcome.. (details)
  114. Issue #792: remove self messaging of OutboudMappingProcessorActor; remove unnecessary parts of AbstractGraphActor; fix logger thread safety. (details)
  115. Issue #792: separate inbound mapping processor actor into 2 actors. (details)
  116. Issue #792: delete duplicate serialVersionUID from ConnectionIdInvalidException. (details)
  117. Issue #792: Fix consumer actor tests and a NullPointerException in AmqpConsumerActor. (details)
  118. Issue #792: document declared-acks. (details)
  119. Issue #792: allow WebSocketAuthorizationEnforcer to extend DittoHeaders. (details)
  120. Issue #792: fixed wrong logic in checking for fully resolved ack labels in DittoProtocolSubImpl (details)
  121. Issue #792: Move algebraic datatype MappingOutcome to own package to enforce visibility. (details)
  122. Issue #792: fixed resolving target issued ack labels where they were not yet resolved (details)
  123. ConnectionIdPlaceholder now only accepts ConnectionIds (details)
  124. Issue #792: review: add correlationId to logger where missing (details)
  125. allow connection IDs with a lengt of 80 (details)
  126. Issue #792: doc review: fixed some typos (details)
  127. fix unit test (details)
  128. For live signals it's required to restore command connectivity headers (details)
  129. added IoT WG community day status update slides (details)
  130. added some documentation about SSO with OpenID connect in the browser (details)
  131. Issue #792: make global/fallback timeouts for AMQP 1.0 connections configurable (details)
  132. Issue #792: exclude InboundDispatchingActor from receiving RetrieveAddressStatus messages (details)
  133. Issue #792: monitor successfully and failed publishing of outbound signals (details)
  134. Issue #792: fixed duplicated monitored failed publishing of outbound signals (details)
  135. Issue #792: fixed duplicated monitored success publishing of outbound signals (dependent on whether an auto issued ack is created or not) (details)
  136. Issue #792: fixed that a sent live message to a target containing an issued ack still contained that auto issued ack as "requested-acks" in its headers (details)
  137. Issue #792: undid monitoring publish success when no commandResponse (ack or live) was created when publishing a signal (details)
  138. Issue #792: fixed filtering of "requsted-acks" for connections without declared source acks (details)
  139. Issue #792: reverted removing issued acks from header as this breaks auto ack issuing (details)
  140. Issue #792: adjusted signal to be mapped to adaptable right before that step to filter out "issued acks" by targets from the "requested-acks" header (details)
  141. Issue #792: Fix 500 for HTTP requests with invalid requested-acks. (details)
  142. Issue #792: verify that query commands with ack requests do not cause redelivery. (details)
  143. Test header resetting in Ack.Agg.Actor and fix it. (details)
  144. Test recording of timer duration above 1s. (details)
  145. Fix recording of timer duration above 1s. (details)
  146. updated slide with todays GH stars (details)
  147. Issue #792: removed HTTP headers from being added to messages sent via HTTP POST (details)
  148. fixed using thread-safe loggers where we need to (details)
  149. Issue #792: ensure AcknowledgementLabelNotDeclaredException is mapped with the correct topic path information. (details)
  150. provide more explicit information in AcknowledgementLabelInvalidException (details)
  151. Replace exclamation marks with dots + reduce streaming chaing (details)
  152. Make base client actor more robust by catching DittoRuntimeExceptions (details)
  153. Implementing RequestedAcksValueValidator to fail fast (details)
  154. Issue #792: reuse AbstractHttpRequestActor.handleDittoRuntimeException; remove unused imports in HttpRequestActorTest. (details)
  155. Issue #792: fix metric counting/logging inconsistencies (details)
  156. Issue #792: removed unused method (details)
  157. Wrap sending the Amqp messages in a stream with a preceding queue/buffer (details)
  158. Make clear that WebSockets are not meant to be used for horizontal scaling (details)
  159. Issue #792: fixed/adjusted acknowledgement logging texts for connectionLogger (details)
  160. fixes #844: "location" header was not read when provided by external headers (details)
  161. Issue #792: added MessageMapper id to connectionLog statements about mapped/dropped (and error) (details)
  162. Issue #792: fixed mapping texts which had the wrong direction (details)
  163. Make protocol of OAuth providers configurable. (details)
  164. Set response-required to false for responses and events (details)
  165. updated CQs (details)
  166. Provide second constructor to allow providing a non static category for (details)
  167. Issue #792: documentation review: added "warning" sections for clarifying that the WS is not intended to be used as scaling out or doing HA (details)
  168. Issue #792: review: restore DittoHeaders on a best effort basis in InboundMappingProcessor in order to retain e.g. "reply-to" required to find out where to send an error response to (details)
  169. Issue #792: Review: Add argument matchers to SendingTest. (details)
  170. Add StoppedKamonTimer.getElapsedNano; fix logging. (details)
  171. Issue #792: fixed merging of "best effort headers" with already existing DittoHeaders (details)
  172. adjusted all DittoRuntimeExceptions to overwrite setDittoHeaders(DittoHeaders) method in order to preserve the type of the exception; unfortunately this can't be fixed without major changes to DittoRuntimeException (details)
  173. #844: fixed header case sensitivity for CheckExternalFilter used in HeaderTranslator (details)
  174. Issue #792: added best effort fallback for determining entity id for exceptions which did not yet pass the protocol adapter (details)
  175. close streaming session when an invalid jwt is provided (details)
  176. Add tests for new introduced publisher-queue (details)
  177. fix javadoc (details)
  178. code wrapping was required. added closing bracket (details)
  179. Issue #792: adjusted blogpost date about acks to today (details)
  180. Add JavaDocs and some minor refactorings of the newly integrated pusblisher-queue (details)
  181. Introduce SilentlyFailingRevocationChecker (details)
  182. Add the new config values to the new config tests, which were introduced in the last merge (details)
  183. AmqpPublisherActorTest: Prevent test failure due to low timeout. (details)
  184. Review: AmqpPublisherActor: move non-thread-safe producer lookup to the actor's thread; format code; fix comment; do not request ack for the congesting messages in AmqpPublisherActorTest. (details)
  185. formatting (details)
  186. fix test after merge (details)
  187. Deprecate topic:entityId placeholder and introduce topic:entityName placeholder (details)
  188. document new placeholder topic:entityName and deprecate topic:entityId (details)
  189. Log handling of http response for http forwarding connection in connection logs (details)
  190. Make revocation check optional at the trust-manager level. (details)
  191. make connection logger a field of BasePublisherActor (details)
  192. Make connectionLogger field in DittoTrustManager non nullable (details)
  193. Make hostname non nullable since it was only null in test cases (details)
  194. delegateWithoutRevocationCheck can never be null (details)
  195. Add 1.4.0 release notes. (details)
Commit b5d315ae8562c90fdaea7cc470737380f4d7919b by Juergen Fickel
Issue #773: `ThingCommandEnforcement` now uses its own `DittoLogger` instead of the `DittoDiagnosticLoggingAdapter` of its parent.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/AbstractEnforcement.java (diff)
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/ThingCommandEnforcement.java (diff)
Commit 80cb0030ded13450724e8ddfc2e730dac89a08dd by Juergen Fickel
Issue #773: Got rid of unnecessary `Optional`s within `ThingCommandEnforcement` to reduce complexity of the class and thus improve understandability.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/ThingCommandEnforcement.java (diff)
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/LiveSignalEnforcement.java (diff)
Commit 02f0116ed794f00c95bce9726c4c6ea224982321 by Juergen Fickel
Issue #773: Use DittoLogger to set correlation ID in `PreEnforcer`.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/PreEnforcer.java (diff)
Commit e70bde147e5c96b689af33f5a266a971418f5cf6 by Juergen Fickel
Issue #773: Renamed variables and parameters to make code easier to understand.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/EnforcementScheduler.java (diff)
Commit d6a67e1a2d953a81129754266b831f48ec7978be by Juergen Fickel
Issue #773: Introduced `ThreadSafeDittoLogger` type and an immutable implementation thereof.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was addedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/ThreadSafeDittoLogger.java
The file was addedservices/utils/akka/src/test/java/org/slf4j/impl/ObservableMdcAdapter.java
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DittoLoggerFactory.java (diff)
The file was addedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableThreadSafeDittoLogger.java
The file was addedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableThreadSafeDittoLoggerTest.java
The file was addedservices/utils/akka/src/test/java/org/slf4j/impl/StaticMDCBinder.java
Commit ea3658481593b99950e3a27aebc5a643b3804b9b by Juergen Fickel
Issue #773: Added "mixin" interface `WithMdcEntry` to allow the setting of arbitrary MDC values to a logger.
Implemented `WithMdcEntry` for `ImmutableThreadSafeDittoLogger`.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was addedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/DefaultMdcEntryTest.java
The file was addedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/LoggingFactory.java
The file was addedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultMdcEntry.java
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/ThreadSafeDittoLogger.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableThreadSafeDittoLogger.java (diff)
The file was addedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/MdcEntry.java
The file was addedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/CommonMdcEntryKey.java
The file was addedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/WithMdcEntry.java
The file was modifiedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableThreadSafeDittoLoggerTest.java (diff)
Commit 00e605f8929e5ceb26a715beae1dfa252341c8f1 by Juergen Fickel
Issue #773: Use `ThreadSafeDittoLogger` in `ThingCommandEnforcement` and `MessageMappingProcessorActor`.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was addedservices/connectivity/util/src/main/java/org/eclipse/ditto/services/connectivity/util/package-info.java
The file was addedservices/connectivity/util/src/main/java/org/eclipse/ditto/services/connectivity/util/ConnectivityMdcEntryKey.java
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/ThingCommandEnforcement.java (diff)
The file was modifiedservices/concierge/enforcement/src/test/java/org/eclipse/ditto/services/concierge/enforcement/ThingCommandEnforcementTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/util/src/main/java/org/eclipse/ditto/services/connectivity/util/ConnectionLogUtil.java (diff)
Commit f281f9b3e28aeb2ca0e893d7c41a7bc5a9ea337e by Juergen Fickel
Issue #773: Allow to set arbitrary context values to `DittoLogger` and some refactorings:
* Made `WithMdcEntry` more type safe.
* Made `CapturingMdcAdapterObserver` usable for other unit tests.
* Added unit test for `DefaultAutoCloseableSlf4jLogger`
* Added unit test for `DefaultDittoLogger`.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/WithMdcEntry.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DittoLogger.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultAutoCloseableSlf4jLogger.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableThreadSafeDittoLogger.java (diff)
The file was addedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/CapturingMdcAdapterObserver.java
The file was addedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/DefaultAutoCloseableSlf4jLoggerTest.java
The file was modifiedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableThreadSafeDittoLoggerTest.java (diff)
The file was addedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDittoLoggerTest.java
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/AutoCloseableSlf4jLogger.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDittoLogger.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/AutoClosingSlf4jLogger.java (diff)
Commit eb9ca0f239521ab60f54023c332d923b5d354894 by Juergen Fickel
Issue #773: Allow to set arbitrary context values to `DittoDiagnosticLoggingAdapter` and added unit tests.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/DittoDiagnosticLoggingAdapter.scala (diff)
The file was addedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDiagnosticLoggingAdapterTest.java
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDittoDiagnosticLoggingAdapter.java (diff)
The file was modifiedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/AbstractDiagnosticLoggingAdapter.scala (diff)
The file was addedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/MdcEntrySettable.scala
The file was addedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDittoDiagnosticLoggingAdapterTest.java
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDiagnosticLoggingAdapter.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/AutoDiscardingDiagnosticLoggingAdapter.java (diff)
Commit 7430486f6fcf7d65071cacf2f431a968ed545661 by Juergen Fickel
Issue #773: Removed superfluous method delegations from direct sub-classes of `AbstractDiagnostincLoggingAdapter`.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDiagnosticLoggingAdapterTest.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDiagnosticLoggingAdapter.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/AutoDiscardingDiagnosticLoggingAdapter.java (diff)
The file was modifiedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDittoDiagnosticLoggingAdapterTest.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDittoDiagnosticLoggingAdapter.java (diff)
Commit b672a5ec49f00364172259616065b530ea4c2e4b by Juergen Fickel
Issue #773: Introduced `ThreadSafeDittoDiagnosticLoggingAdapter` as well as an immutable implementation thereof.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was addedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/ThreadSafeDittoDiagnosticLoggingAdapter.scala
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DittoLoggerFactory.java (diff)
The file was addedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableDittoDiagnosticLoggingAdapter.java
The file was addedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableDittoDiagnosticLoggingAdapterTest.java
Commit 2bdd79820c5b4d2f33f13fb0ce1dda8469836254 by Juergen Fickel
Issue #773: Made `ThreadSafeDittoDiagnosticLoggingAdapter` a `LoggingAdapter` instead of a `DiagnosticLoggingAdapter` as setting the MDC directly would make immutable implementation impossible. Renamed the classes accordingly. Simplified `ImmutableDittoLoggingAdapter`.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was removedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/ThreadSafeDittoDiagnosticLoggingAdapter.scala
The file was removedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableDittoDiagnosticLoggingAdapter.java
The file was addedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableDittoLoggingAdapter.java
The file was addedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/DiagnosticBusLogging.scala
The file was addedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableDittoLoggingAdapterTest.java
The file was addedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/ThreadSafeDittoLoggingAdapter.scala
The file was removedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableDittoDiagnosticLoggingAdapterTest.java
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DittoLoggerFactory.java (diff)
Commit a3a01e5965e977ecbe0719f9c88c20029f982d06 by Juergen Fickel
Issue #773: Renamed `ImmutableThreadSafeDittoLogger` to `ImmutableDittoLogger` to remove redundancy in class name.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was removedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableThreadSafeDittoLogger.java
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DittoLoggerFactory.java (diff)
The file was addedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableDittoLogger.java
The file was removedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableThreadSafeDittoLoggerTest.java
The file was addedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableDittoLoggerTest.java
Commit 5d510622906a8788f39f94cd370f2c92cf188597 by Yufei Cai
Issue #792: add scaffold for another DData for uniqueness constraint on ack labels; minor improvements.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/things/starter/src/main/java/org/eclipse/ditto/services/things/starter/DefaultThingPersistenceActorPropsFactory.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/Publisher.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubUpdater.java (diff)
The file was modifiedservices/models/things/src/main/java/org/eclipse/ditto/services/models/things/ThingEventPubSubFactory.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActorPropsFactory.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/compressed/CompressedDDataHandler.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/LiveSignalPubSubFactory.java (diff)
The file was modifiedservices/things/starter/src/main/java/org/eclipse/ditto/services/things/starter/ThingsRootActor.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/PersistenceActorTestBase.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/PubUpdater.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingSupervisorActor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubSupervisor.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/TestPubSubFactory.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/Subscriber.java (diff)
The file was modifiedservices/things/starter/src/test/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceOperationsActorIT.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/compressed/CompressedDData.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/AbstractPubSubFactory.java (diff)
Commit ef7eb69c54c2a6c991a3b43af9296e0f90568635 by Yufei Cai
Issue #792: Add a distributed data without lossy compression for uniqueness constraint.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractDDataHandler.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/compressed/CompressedUpdate.java (diff)
The file was modifiedservices/models/things/src/main/java/org/eclipse/ditto/services/models/things/ThingEventPubSubFactory.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/literal/package-info.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/literal/LiteralSubscriptions.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/AbstractPubSubFactory.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractSubscriptions.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/IndelUpdate.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/literal/LiteralUpdate.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/literal/LiteralDData.java
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractSubscriptionsTest.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/LiveSignalPubSubFactory.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/TestPubSubFactory.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractIndelUpdate.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/compressed/CompressedDDataHandler.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/literal/LiteralDDataHandler.java
Commit 7b942473302462916ded50a3bf46a1f70fbc127f by Yufei Cai
Issue #792: Bootstrap AcksUpdater; remove terminated subscribers from DData.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSub.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractUpdater.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubSupervisor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSubImpl.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactoryTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractPubSubSupervisor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractSubscriptions.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AcksUpdater.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/SubscriptionsReader.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/AbstractPubSubFactory.java (diff)
Commit 1d92c09c938b6ba00b3202029010cbf091b614e3 by Yufei Cai
Issue #792: AcksUpdater: detect local losers of race conditions.

TODO: decouple subscription with ack label declaration.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractDDataHandler.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/Subscriptions.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSubImpl.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubSupervisor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/TopicData.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AcksUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractSubscriptions.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/DDataReader.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/SubscriptionsReader.java (diff)
Commit 07e5c669c4d3ea8dcf4cb974610ed609efdda815 by Yufei Cai
Issue #792: remove SubUpdater dependency from AcksUpdater.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AcksUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubSupervisor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractUpdater.java (diff)
Commit 6b82070ccbdcc3d48bcaac9e07b091f2d845f9ec by Yufei Cai
Issue #792: allow ack label declarations at DistributedSub.

- Added 2 tests, 1 failing.

- Added dedicated exception for duplication of ack label declarations.

- Log expected "CurrentClusterState" messages at INFO level.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSubImpl.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractDDataHandler.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/PubUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactoryTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSub.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AcksUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubSupervisor.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/AcknowledgementLabelNotUniqueException.java
Commit 0cce546b6ac296ccfde527360aef7368ac0a43a0 by Juergen Fickel
Issue #773: Manually merged test cases from master branch.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDittoDiagnosticLoggingAdapterTest.java (diff)
Commit e105b012ea984fb2664e3a32fcfdd58402a43725 by Yufei Cai
Issue #792: pubsub: extract ClusterMemberRemovedAware mixin; add seqNr to SubAck so that they are not sent out prematurely.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubUpdater.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/ClusterMemberRemovedAware.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/PubUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactoryTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AcksUpdater.java (diff)
Commit d38c052af30ee7c5cf756c26653fca192debddf9 by Yufei Cai
 Issue #792: move AcknowledgementLabelNotUniqueException to ditto.signal.acks.base.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was removedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/AcknowledgementLabelNotUniqueException.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AcksUpdater.java (diff)
The file was addedsignals/acks/base/src/main/java/org/eclipse/ditto/signals/acks/base/AcknowledgementLabelNotUniqueException.java
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactoryTest.java (diff)
Commit 6253fcc206bc319aa4b8767bbbf6529d2ec256cb by Juergen Fickel
Issue #773: Create a copy of MDC when getting MDC from DiagnosticLoggingAdapter as it returns an immutable map. This differs from the actual documentation of Akka and caused exceptions.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDiagnosticLoggingAdapter.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableDittoLoggingAdapter.java (diff)
Commit e29e64be9d700660959bee3aa8afe4fae731fc87 by Juergen Fickel
Issue #773: Use `ThreadSafeDittoLogger` for logging and some refactoring:
* Re-ordered methods so that they are close to their usage.
* Got rid of creating internal `Optional`s as they are not really necessary to hopefully improve performance a bit.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActor.java (diff)
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/LiveSignalEnforcement.java (diff)
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/ThingCommandEnforcement.java (diff)
Commit 385a7e5c53d336dcf79e1734a0ee3c338d570a91 by Juergen Fickel
Issue #773: Removed dedicated methods for setting and discarding correlation ID from `AbstractDiagnosticLoggingAdapter` as the more generic method 'putMdcEntry' can be used instead.
Additionally, added methods to `DittoDiagnosticLoggingAdapter` for setting MDC values (`setMdc...`) until they get discarded as counterpart for setting MDC values (`withMdc...`) for only one log statement.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/AutoDiscardingDiagnosticLoggingAdapter.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDiagnosticLoggingAdapter.java (diff)
The file was modifiedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/AbstractDiagnosticLoggingAdapter.scala (diff)
The file was modifiedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDittoDiagnosticLoggingAdapterTest.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDittoDiagnosticLoggingAdapter.java (diff)
The file was modifiedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/DittoDiagnosticLoggingAdapter.scala (diff)
The file was modifiedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/MdcEntrySettable.scala (diff)
The file was modifiedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDiagnosticLoggingAdapterTest.java (diff)
Commit 8adb47396bdb64202a52a2bc41cf93fb1f0abd10 by Juergen Fickel
Issue #773: Only make copy of MDC if is going to be changed.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableDittoLoggingAdapter.java (diff)
Commit ab8817b09bbc2668e93ed09fbc3eb8a72027410f by Juergen Fickel
Issue #773: Use `ThreadSafeDittoLoggingAdapter` for logging in `BasePublisherActor` and `BaseClientActor` as well as in their sub-classes.
The used logger has always a connection ID.
Also some refactoring:
* Extracted `OutboundSignalToExternalMessage` from `BasePublisherActor` as its functionality was not really part of that actor.
* Extracted `ErrorConverter` as abstract class `ExceptionToAcknowledgementConverter` from `BasePublisherActor` as it has sub-classes.
* Moved `SendingOrDropped` and its implementations to package level. Moved implementations to specific existing implementation classes.
* Re-ordered methods so that they are close to their usage.
* Added unit tests.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/DefaultExceptionToAcknowledgementConverterTest.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultMonitoringConfig.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/JMSPropertyMapper.java (diff)
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/OutboundSignalToExternalMessageTest.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt5SubscriptionHandler.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/DefaultExceptionToAcknowledgementConverter.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/Dropped.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundSignalToExternalMessage.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/AbstractMqttSubscriptionHandler.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt5ClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt3SubscriptionHandler.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessor.java (diff)
The file was removedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActorTest.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQPublisherActor.java (diff)
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/DroppedTest.java
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/SendingTest.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActor.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ExceptionToAcknowledgementConverter.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt3ClientActor.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/SendingContext.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/AbstractMqttClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/AbstractMqttPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActor.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/SendingOrDropped.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorTest.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/Sending.java
Commit f25ef1b1e9e4594d5943859d002b78f26983b748 by Juergen Fickel
Issue #773: Fixed unit test.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaClientActor.java (diff)
Commit 09ce8c264484274d9cbdf3f6a54bff56b8d0ead2 by Juergen Fickel
Issue #773: Fixed unit tests.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessor.java (diff)
Commit c913b490d817fe56b96d6b163071a4784d447ecc by Juergen Fickel
Issue #773: Fixed more unit tests.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractConsumerActorTest.java (diff)
Commit 3849f8bb84921086b6706e558f2abacc15fa0e0e by Juergen Fickel
Issue #773: Fixed even more unit tests.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractConsumerActorTest.java (diff)
Commit b2f0108966890799ea3147515bef71a9760aabb4 by Thomas Jaeckle
Issue #773: review: scaladoc styleguide fixes
* applied scaladoc styleguide (was applied only half way) for .scala files

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/MdcEntrySettable.scala (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultMdcEntry.java (diff)
The file was modifiedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/DiagnosticBusLogging.scala (diff)
The file was modifiedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/AkkaClassLoader.scala (diff)
The file was modifiedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/ThreadSafeDittoLoggingAdapter.scala (diff)
The file was modifiedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/AbstractDiagnosticLoggingAdapter.scala (diff)
The file was modifiedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/DittoDiagnosticLoggingAdapter.scala (diff)
Commit 17c6ac3a272b13e9a9c108f0e8ece6aeb72efd11 by Yufei Cai
Fix a concurrency issue in AcksUpdater.

- Move resetting of "localSubscriptionsChanged" and "nextWriteConsistency"
  to safe locations.

- Always perform READ_ALL on clock ticks in order to discover
  local losers of races.

- In remote-conflict test, wait 1 clock cycle before the assertion
  to avoid racing.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactoryTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractDDataHandler.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/DDataReader.java (diff)
The file was modifiedservices/utils/pubsub/src/main/resources/reference.conf (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AcksUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubUpdater.java (diff)
Commit bc15f104aa7b6fa97f75eafe79f75c7bfa1f51e8 by Yufei Cai
Issue #792: stop using localSubscriptionsChanged in AcksUpdater; add tests for race conditions; fix remote conflict test.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AcksUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactoryTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/ClusterMemberRemovedAware.java (diff)
The file was modifiedservices/utils/pubsub/src/test/resources/pubsub-factory-test.conf (diff)
Commit ad4983c5b2a073b891b56a8d122c2dac52a7f98f by Thomas Jaeckle
Issue #773: fixed unit tests by fixing mocking of loggers

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActorTest.java (diff)
Commit 0ea036c40160a7dc2e5ecc5ffe6184020de68d72 by Yufei Cai
Issue #792: simplify AcksUpdater; update documentation and test.

- Removed non-local ddata ops in AcksUpdater.
- Rely on cluster gossip for eventual consistency.

AcksUpdater becomes much simpler and performant at the cost of
increased probability for racing. Receiving a SubAck is no
guarantee that all subsequent declarations of the same labels
will fail on all nodes.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactoryTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubSupervisor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubUpdater.java (diff)
The file was modifiedservices/utils/namespaces/src/main/java/org/eclipse/ditto/services/utils/namespaces/BlockedNamespaces.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AcksUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractDDataHandler.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/DDataReader.java (diff)
The file was modifiedservices/utils/ddata/src/main/java/org/eclipse/ditto/services/utils/ddata/DistributedData.java (diff)
Commit 2a07fa6d0d964e5b67d31ce72fc288e770abd2c2 by Yufei Cai
Issue #792: make authentication non-blocking; update TODOs; make query parameters accessible to WebsocketRoute.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/AuthenticationChain.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/TimeMeasuringAuthenticationProvider.java (diff)
The file was modifiedservices/gateway/security/src/test/java/org/eclipse/ditto/services/gateway/security/authentication/AuthenticationChainTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubSupervisor.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/AuthenticationProvider.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/RootRoute.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtAuthenticationProvider.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/preauth/PreAuthenticatedAuthenticationProvider.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/AuthenticationResultWaiter.java (diff)
The file was modifiedservices/gateway/security/src/test/java/org/eclipse/ditto/services/gateway/security/authentication/preauth/PreAuthenticatedAuthenticationProviderTest.java (diff)
The file was modifiedservices/gateway/security/src/test/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtAuthenticationProviderTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractUpdater.java (diff)
Commit 481aed46e468592d62389e82411c286e4954760e by Juergen Fickel
Issue #773: Fixed compilation error: implementations have to use immutable Seq.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableDittoLoggingAdapter.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDittoDiagnosticLoggingAdapter.java (diff)
Commit 4b4e2eb25db426c34ae59a51a450cf9b5f6f58fc by Yufei Cai
Issue #792: Make ack label declaration optional in PubSubFactory; disconnect websocket on AcknowledgementLabelNotUniqueException.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/gateway/starter/src/main/resources/gateway.conf (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeaders.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeadersBuilder.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/AbstractDittoHeaders.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeaderDefinition.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/DittoProtocolSub.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/DittoProtocolSubImpl.java (diff)
The file was modifiedmodel/base/src/test/java/org/eclipse/ditto/model/base/headers/ImmutableDittoHeadersTest.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/AbstractDittoHeadersBuilder.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubSupervisor.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/LiveSignalPubSubFactory.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/sse/ThingsSseRouteBuilder.java (diff)
The file was modifiedservices/gateway/streaming/src/test/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActorHeaderInteractionTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/AbstractPubSubFactory.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AcksUpdater.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebSocketRoute.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/Connect.java (diff)
Commit 1a09af5d0df238372f9a839d947bc109eff8cb6e by Yufei Cai
Issue #792: fix StreamingSessionActorHeaderInteractionTest; remove unused fields; fix compile errors.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/starter/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceOperationsActorIT.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/TestConstants.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
The file was modifiedmodel/connectivity/src/test/java/org/eclipse/ditto/model/connectivity/TestConstants.java (diff)
Commit 4acc6ef3e8a1dc2d9215a9180ef5e7603e1d675d by Yufei Cai
Issue #792: relax ack label regex.

- Max length increased from 64 to 100 to fit an additional UUID.
- Make ':' a permitted character.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedmodel/base/src/test/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelsTest.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabels.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/ImmutableAcknowledgementLabel.java (diff)
Commit 839fd5566802205fb7f46e52fd29e455fd705799 by Yannic Klem
review of declared acks in pubsub

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/utils/namespaces/src/main/java/org/eclipse/ditto/services/utils/namespaces/BlockedNamespaces.java (diff)
The file was modifiedservices/utils/ddata/src/main/java/org/eclipse/ditto/services/utils/ddata/DistributedData.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/LiveSignalPubSubFactory.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractUpdater.java (diff)
Commit c866757324562588a16f3f8806d154c62366da11 by Thomas Jaeckle
added correlation-id when "retrievePartialThing" / enriching outbound signals in MessageMappingProcessorActor

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActor.java (diff)
Commit d400f39564748f37256ce94e3d5bf35305b3e36d by Thomas Jaeckle
fixed adding correlation-id for "RetrieveThing" commands caused by enrichment

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActor.java (diff)
The file was modifiedservices/models/signalenrichment/src/main/java/org/eclipse/ditto/services/models/signalenrichment/ByRoundTripSignalEnrichmentFacade.java (diff)
Commit 390a73dfba1626ed666be8619589ed81acdc4ffb by Yannic Klem
Fixing dependecies

* connectivity model should not depend from placeholder model
* Moves classes from connectivity model to connectivity service model
* Moves classes from connectivity model to placeholder model

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was removedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/EnforcementFactoryFactory.java
The file was modifiedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/PlaceholderFactory.java (diff)
The file was addedservices/models/connectivity/src/test/java/org/eclipse/ditto/services/models/connectivity/ImmutableEnforcementFilterTest.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt5ConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/AbstractMqttConsumerActor.java (diff)
The file was addedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/ImmutableEnforcementFilter.java
The file was modifiedmodel/connectivity/pom.xml (diff)
The file was removedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ImmutableEnforcementFilter.java
The file was addedmodel/placeholders/src/test/java/org/eclipse/ditto/model/placeholders/ImmutableSourceAddressPlaceholderTest.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/AbstractMqttValidator.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectivityModelFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActor.java (diff)
The file was addedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/ImmutableSourceAddressPlaceholder.java
The file was addedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/EnforcementFactoryFactory.java
The file was removedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/SourceAddressPlaceholder.java
The file was removedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ImmutableSourceAddressPlaceholder.java
The file was modifiedmodel/placeholders/pom.xml (diff)
The file was addedservices/models/connectivity/src/test/java/org/eclipse/ditto/services/models/connectivity/SimplePlaceholder.java
The file was removedmodel/connectivity/src/test/java/org/eclipse/ditto/model/connectivity/ImmutableSourceAddressPlaceholderTest.java
The file was addedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/ImmutableEnforcementFilterFactory.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorTest.java (diff)
The file was removedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ImmutableEnforcementFilterFactory.java
The file was removedmodel/connectivity/src/test/java/org/eclipse/ditto/model/connectivity/ImmutableEnforcementFilterTest.java
The file was addedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/SourceAddressPlaceholder.java
The file was removedmodel/connectivity/src/test/java/org/eclipse/ditto/model/connectivity/SimplePlaceholder.java
Commit da2489c6aa8364e32894105fd5628f108c4c223a by Yannic Klem
Add implementation for ConnectionPlaceholder to resolve the ID

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was addedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/ImmutableConnectionPlaceholder.java
The file was addedmodel/placeholders/src/test/java/org/eclipse/ditto/model/placeholders/ImmutableConnectionPlaceholderTest.java
Commit e4811d1619556578bc6904c3caa92bdb81283267 by Juergen Fickel
Issue #773: Post-merger adjustments:
* Got rid of `CommandResponseOrAcknowledgement` as it was not used as intended. It suffices to work with `CommandResponse` as `Acknowledgement` implements this type, too.
* Refactored `Sending` to reflect changed behavior. Adjusted unit tests accordingly.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/SendingOrDropped.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/DroppedTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/SendingTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/Dropped.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/AbstractMqttPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/Sending.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherActor.java (diff)
Commit ceeb2a3c281c2d721bc24b3a0a6d1cafead246df by Yufei Cai
Issue #792: Make -AutthorizationEnforcer asynchronous for Websocket and SSE.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebSocketAuthorizationEnforcer.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/sse/ThingsSseRouteBuilder.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelInvalidException.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/sse/SseAuthorizationEnforcer.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebSocketRoute.java (diff)
Commit 1da033c6c0af5d994ded139f7ee4980bc1b24bfa by Yufei Cai
Issue #792: stop testing DummyQueryCommand.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/test/src/test/java/org/eclipse/ditto/services/utils/test/GlobalCommandRegistryTestCases.java (diff)
The file was modifiedsignals/commands/base/src/test/java/org/eclipse/ditto/signals/commands/base/AbstractCommandTest.java (diff)
Commit 2a1b7b6b15700d1ce69cd3a748c87321784919f2 by Yufei Cai
Issue #792: Add "declaredAcks" to connection sources.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/Source.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/SourceBuilder.java (diff)
The file was modifiedmodel/connectivity/src/test/java/org/eclipse/ditto/model/connectivity/ImmutableSourceTest.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ImmutableSource.java (diff)
Commit 1cba5475bed8de777d4631e77e24d1da260421fe by Yufei Cai
Issue #792: validate that issued and declared acks of connections are prefixed with the connection ID.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
Commit 2c5d05f9645bf40104b2437d218892bca6a4285b by Yufei Cai
Issue #792: maintain "ackLabelDeclared" flag in ConnectionPersistenceActor.

Changes:

- Added an interval config for how often connection persistence actor
  declares ack labels for as long as it is not successful.

- Permit connection persistence actor to relinquish previously
  declared ack labels. This is because the connection persistence
  actor of a closed or deleted connection stays alive even as
  it receives nothing from pubsub.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/resources/connection-test.conf (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/TestConstants.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractUpdater.java (diff)
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/DittoProtocolSubImpl.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/ConnectionConfig.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultConnectionConfig.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/DittoProtocolSub.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactoryTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubSupervisor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSub.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSubImpl.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultConnectionConfigTest.java (diff)
Commit d5d88be6f8353e883fec333f7d9e3f4ad5dc47c3 by Yufei Cai
Issue #792: test connection ack label declaration; fix tests.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/TestConstants.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/connectivity/starter/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceOperationsActorIT.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
Commit 0320d7464198d69f784707c5ac96d9d2a35911b5 by Yufei Cai
Issue #792: deny acknowledgements from WS and connections unless declared.

- Added AcknowledgementLabelNotDeclaredException.

- Moved AcknowledgementLabelNotUnniqueException to the same package.

- Remove ack requests of outgoing signals not declared for the WS/connection.

- Reply with AcknowledgementLabelNotDeclaredException on incoming ack
  with non-declared label.

Still TODO:

1. Ensure AcknowledgementLabelNotUniqueException gets published to reply targets.

2. Discriminate incoming acknowledgements by the source they come from,
   so that one source may not send the ack declared for another source.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was removedsignals/acks/base/src/main/java/org/eclipse/ditto/signals/acks/base/AcknowledgementLabelNotUniqueException.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AcksUpdater.java (diff)
The file was addedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelNotDeclaredException.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/models/acks/src/main/java/org/eclipse/ditto/services/models/acks/AcknowledgementForwarderActor.java (diff)
The file was addedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelNotUniqueException.java
The file was modifiedservices/models/acks/src/test/java/org/eclipse/ditto/services/models/acks/AcknowledgementForwarderActorTest.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactoryTest.java (diff)
The file was modifiedservices/models/acks/src/test/java/org/eclipse/ditto/services/models/acks/AcknowledgementForwarderActorStarterTest.java (diff)
The file was modifiedservices/models/acks/src/main/java/org/eclipse/ditto/services/models/acks/AcknowledgementForwarderActorStarter.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
Commit b39656d50316c0700aa8b0e185fd8d185dd4a550 by Yufei Cai
Issue #792: ensure Ack.LabelNotDeclaredException gets published to reply targets; discriminate incoming acknowledgements by their source.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
Commit 312693cdabc87316f2aa178b1a41e0c3d56f1db5 by Yufei Cai
Issue #792: fix MessageMappingProcessorActorHeaderInteractionTest; test StreamingSessionActor's acknowledgement handling.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActor.java (diff)
The file was addedservices/gateway/streaming/src/test/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActorTest.java
Commit 96299b098df72866166d62d8abaab72557552563 by Yufei Cai
Issue #792: Test that WS streams complete when StreamingSessionActor stops.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
The file was modifiedservices/gateway/streaming/src/test/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActorTest.java (diff)
Commit e01d1e69926b8afa5be90a91122193694d2a6d05 by Yannic Klem
Use ConnectionIdPlaceholder in Resolvers

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActorTest.java (diff)
The file was addedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/ConnectionIdPlaceholder.java
The file was addedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/ImmutableConnectionIdPlaceholder.java
The file was modifiedmodel/placeholders/src/test/java/org/eclipse/ditto/model/placeholders/ImmutableExpressionResolverTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessor.java (diff)
The file was modifiedmodel/placeholders/src/test/java/org/eclipse/ditto/model/placeholders/ImmutableConnectionPlaceholderTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/Resolvers.java (diff)
The file was removedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/ImmutableConnectionPlaceholder.java
The file was modifiedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/PlaceholderFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActor.java (diff)
Commit 3a79467cda3dc86e9243ec8abc439c9fa16397ae by Yannic Klem
Resolve connection ID placeholder in declared and issued acks

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedmodel/base/src/test/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelsTest.java (diff)
The file was modifiedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/PlaceholderFactory.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabels.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
Commit 674a4e6a5c893e4de7555ad9dfdb8720e37d7952 by Yannic Klem
Review of declaration of acks for websocket connections

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/AuthenticationChain.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/AuthenticationResultWaiter.java (diff)
Commit 147b38387eb690787583bc1394a38fa761854862 by Juergen Fickel
Issue #773: Post-merger adjustments: Fixed compilation errors.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActorTest.java (diff)
Commit efcece4f317a9be434d2c4bad49ef8731e8b5fdd by Thomas Jaeckle
added metric about acknowledgements (whether they were a success and redeliver status)
* enhanded metric about message mapping with connectionType

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt3ConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MappingTimer.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt5ConsumerActor.java (diff)
The file was modifiedservices/utils/tracing/src/main/java/org/eclipse/ditto/services/utils/tracing/TracingTags.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/AbstractMqttConsumerActor.java (diff)
Commit c894e35c11793c866ec9b5e1a3653133d47d2393 by Yannic Klem
Do not resolve connection ID placeholder in source and target acknowledgements

* It's too error-prone to allow placeholders in declared and issued
  acknowledgements of sources and targets.
* When creating a connection via Devops Command it is required to use the
  ID of the newly created connection instead of placeholders

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedmodel/base/src/test/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelsTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabels.java (diff)
Commit 3f0bf2d94a7620597e6232eacf1462329f90ced0 by Yufei Cai
Issue #792: GlobalCommandRegistryTestCases: exclude Dummy* commands instead of private classes.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/test/src/test/java/org/eclipse/ditto/services/utils/test/GlobalCommandRegistryTestCases.java (diff)
The file was modifiedservices/connectivity/starter/src/test/java/org/eclipse/ditto/services/connectivity/ConnectivityServiceGlobalCommandRegistryTest.java (diff)
Commit 1e13f1d1852847e2bfa711b2719e04f41b03596d by Yufei Cai
Issue #792: Fix review findings and StreamingSessionActorTest.

- Move stubbing before first invocation.
- Move concurrent tasks of StreamingSessionActor from constructor
  to preStart.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
The file was modifiedservices/gateway/streaming/src/test/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActorTest.java (diff)
Commit 23f9c4505e6e4ec605421b33e02de297c6f119eb by Yannic Klem
Handle case of empty acknowledgements list inside declareAcknowledgements

* This way the caller of the method does not have to check this

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/DittoProtocolSubImpl.java (diff)
Commit e85fbd08e55a8b14cad8c586492fa4e3100e049a by Yannic Klem
Split MessageMappingProcessor into Inbound- and OutboundMappingProcessor

* This is a first step in the process of reducing the complexity of
  MessageMappingProcessorActor

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMappingProcessor.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was removedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorTest.java
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessorTest.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActor.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessor.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessor.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMessageMappingProcessorActorTest.java (diff)
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorTest.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessor.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActorTest.java (diff)
Commit 03fed60d650b1423f40dc14a2587f824f13ee990 by Juergen Fickel
Issue #773: Not-thread-safe loggers and logging adapters handle ConcurrentModificationException for cases when they are used by multiple threads.
Had to add a logger name to logging adapters as only SLF4J loggers had a name so far.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultAutoCloseableSlf4jLogger.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DittoLoggerFactory.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/AutoDiscardingDiagnosticLoggingAdapter.java (diff)
The file was modifiedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDiagnosticLoggingAdapterTest.java (diff)
The file was modifiedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/AbstractDiagnosticLoggingAdapter.scala (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDittoDiagnosticLoggingAdapter.java (diff)
The file was modifiedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDittoDiagnosticLoggingAdapterTest.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDiagnosticLoggingAdapter.java (diff)
The file was modifiedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableDittoLoggingAdapterTest.java (diff)
Commit 17dcf479b7fd87d4599daaffe3393011fa4d06ef by Juergen Fickel
Issue #773: Directives are simultaneously executed by multiple threads, thus thread-safe logger has to be used.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/directives/CorrelationIdEnsuringDirective.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/directives/RequestResultLoggingDirective.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/directives/RequestTimeoutHandlingDirective.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/directives/HttpsEnsuringDirective.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/directives/ContentTypeValidationDirective.java (diff)
Commit 4f23bc22262a9a56be65404ee435993eddae7e11 by Yannic Klem
Separate inbound and outbound MessageMappingProcessorActors

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessorActor.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActor.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt5ClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt3ConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorHeaderInteractionTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt5ConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt3ClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/AbstractMqttClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingResultHandler.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java
Commit b254465a6995c9478c0d82f40ecbddce75c46819 by Juergen Fickel
Issue #773: Logger of `WebSocketRoute` is simultaneously called by multiple threads, thus thread-safe logger is used.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebSocketRoute.java (diff)
Commit ddcdd28be21f31da2458126bff637dcd74e092a3 by Yannic Klem
fix unit tests

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/gateway/streaming/src/test/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActorTest.java (diff)
The file was modifiedservices/gateway/streaming/src/test/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActorHeaderInteractionTest.java (diff)
Commit 10a8947591a272a159d69288a3d4c0fb4970ee4c by Thomas Jaeckle
added 1.3 as new docVersion

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifieddocumentation/src/main/resources/_config.yml (diff)
Commit 9c06815443da55f0479979068b2f4490fa222c3b by Thomas Jaeckle
increased binary-compatibility-check version to released 1.3.0

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedpom.xml (diff)
The file was modifiedjson-cbor/pom.xml (diff)
Commit d5ef49a78f3c2798c632ce4caefa3d8ba1d46b09 by Juergen Fickel
Issue #773: Set version of `@since` tags to upcoming Ditto release 1.4.0.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/CommonMdcEntryKey.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/ThreadSafeDittoLogger.java (diff)
The file was modifiedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/MdcEntrySettable.scala (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableDittoLoggingAdapter.java (diff)
The file was modifiedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/AbstractDiagnosticLoggingAdapter.scala (diff)
The file was modifiedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/ThreadSafeDittoLoggingAdapter.scala (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/AutoCloseableSlf4jLogger.java (diff)
The file was modifiedservices/utils/akka/src/main/scala/org/eclipse/ditto/services/utils/akka/logging/DiagnosticBusLogging.scala (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultMdcEntry.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/WithMdcEntry.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DittoLoggerFactory.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/LoggingFactory.java (diff)
The file was modifiedservices/connectivity/util/src/main/java/org/eclipse/ditto/services/connectivity/util/ConnectivityMdcEntryKey.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/ImmutableDittoLogger.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/MdcEntry.java (diff)
Commit d859007efd5a674227435a385674262d97130783 by Yannic Klem
restructure documentation to bring default header values closer to their interaction description

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-acknowledgements.md (diff)
Commit b6240ed8c8bd4c9f3565763a5463b4b2b735744c by Yufei Cai
Issue #792: test target-issued acks handling by connection persistence actor and fix it.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
Commit a842b37686f8e6c24dfe644bbbb0d17acd46b56a by Yannic Klem
Do allow live message responses without enforcing technical acknowledgement

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AbstractCommandAckRequestSetter.java (diff)
The file was addedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectivityInternalErrorException.java
The file was modifiedsignals/commands/messages/src/test/java/org/eclipse/ditto/signals/commands/messages/acks/MessageCommandAckRequestSetterTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorHeaderInteractionTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActor.java (diff)
The file was modifiedservices/models/acks/src/main/java/org/eclipse/ditto/services/models/acks/AcknowledgementAggregatorActor.java (diff)
The file was modifiedsignals/commands/things/src/test/java/org/eclipse/ditto/signals/commands/things/acks/ThingLiveCommandAckRequestSetterTest.java (diff)
The file was modifiedsignals/commands/messages/src/main/java/org/eclipse/ditto/signals/commands/messages/acks/MessageCommandAckRequestSetter.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/acks/ThingLiveCommandAckRequestSetter.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/acks/ThingModifyCommandAckRequestSetter.java (diff)
Commit a40c2888cd36f5f9ccce10eff2cf60040a4a68b8 by Yannic Klem
Consider target ack to be requested if target ack is live-response
and signal is a live signal requiring a response

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActor.java (diff)
Commit b8a77d3224f91721974e4db96dbd054226631880 by Yannic Klem
Add implicit acknowledgement only if requested-acks is non-empty

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/acks/ThingLiveCommandAckRequestSetter.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/acks/ThingModifyCommandAckRequestSetter.java (diff)
The file was modifiedsignals/commands/messages/src/main/java/org/eclipse/ditto/signals/commands/messages/acks/MessageCommandAckRequestSetter.java (diff)
The file was modifiedsignals/commands/messages/src/test/java/org/eclipse/ditto/signals/commands/messages/acks/MessageCommandAckRequestSetterTest.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AbstractCommandAckRequestSetter.java (diff)
The file was modifiedsignals/commands/things/src/test/java/org/eclipse/ditto/signals/commands/things/acks/ThingLiveCommandAckRequestSetterTest.java (diff)
Commit 8d3fa1d5e74a6b3e4b25d6df5cf20a6eaac443cb by Yannic Klem
consider a live response with a non timeout status code to be successful

* This allows to send live responses with error status codes without
  rejecting the initial message in the consumer actor.

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ResponseCollectorActor.java (diff)
The file was modifiedsignals/acks/base/src/main/java/org/eclipse/ditto/signals/acks/base/ImmutableAcknowledgement.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/ResponseCollectorActorTest.java (diff)
The file was modifiedsignals/acks/base/src/test/java/org/eclipse/ditto/signals/acks/base/ImmutableAcknowledgementTest.java (diff)
Commit 9b1d8887464122d4450d8e4ab7dacc1c4a898aa8 by Thomas Jaeckle
fixed that search via SSE was broken
* the "proxyActor" was not configured for the ThingsSseRouteBuilder

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/gateway/starter/src/main/java/org/eclipse/ditto/services/gateway/starter/GatewayRootActor.java (diff)
Commit e913713359f8c26cd69b07d5693650438043fa42 by Yannic Klem
decouple response-required default value from requested acks

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AbstractCommandAckRequestSetter.java (diff)
Commit bc1dfddbd64271547f996a6095d94e867c9622c5 by Yannic Klem
Adjust documentation for header interaction between requested-acks
and live-response

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-acknowledgements.md (diff)
Commit 9434982727872506bba6c7f3bceb6153877577c0 by Yannic Klem
Adjust documentation regarding the default value of response-required

* Default value of response-required does now only depend of the value of timeout

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-acknowledgements.md (diff)
Commit e360fdc9b79b089cd712112af0a0cbac0fece913 by Thomas Jaeckle
review: fixed javadoc errors
* adjusted acknowledgements "Interaction between headers" formatting
*

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/AbstractDittoHeaders.java (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-acknowledgements.md (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/exceptions/DittoRuntimeException.java (diff)
The file was modifiedsignals/acks/base/src/main/java/org/eclipse/ditto/signals/acks/base/ImmutableAcknowledgement.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectivityInternalErrorException.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AbstractCommandAckRequestSetter.java (diff)
Commit 783d10f6f13759ec9fb421a0e8556f4ec2a696de by Yannic Klem
Fixes javadoc and removes telling the exception to a sender

* sender should not be present as this method is called during actor
  initialization and not triggered by a message

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
Commit b0518b314f33bde7961d7c90a7e40791b72c79bb by Thomas Jaeckle
Issue #792: adjusted since javadoc annotations to 1.4.0

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeaders.java (diff)
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/ImmutableEnforcementFilter.java (diff)
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/EnforcementFactoryFactory.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeadersBuilder.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/DittoProtocolSub.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/Source.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ImmutableLogEntry.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeaderDefinition.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSub.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelNotDeclaredException.java (diff)
The file was modifiedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/PlaceholderFactory.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/SourceBuilder.java (diff)
The file was modifiedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/ConnectionIdPlaceholder.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelInvalidException.java (diff)
The file was modifiedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/ImmutableConnectionIdPlaceholder.java (diff)
Commit 5044ae8132eec0b8815e2e73dc0bd117967c0ef7 by Thomas Jaeckle
Issue #792: removed "declared-acks" from DittoHeaderDefinition and DittoHeaders again
* they do not have "signal" reference
* they are only applicable for WebSocket sessions

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/models/acks/src/main/java/org/eclipse/ditto/services/models/acks/AcknowledgementForwarderActor.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeadersBuilder.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractUpdater.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/AbstractDittoHeaders.java (diff)
The file was modifiedmodel/base/src/test/java/org/eclipse/ditto/model/base/headers/ImmutableDittoHeadersTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/Subscriptions.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebSocketRoute.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeaderDefinition.java (diff)
The file was modifiedservices/gateway/util/src/main/java/org/eclipse/ditto/services/gateway/util/config/endpoints/HttpConfig.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractSubscriptions.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeaders.java (diff)
The file was modifiedservices/gateway/starter/src/main/resources/gateway.conf (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/AbstractDittoHeadersBuilder.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/common/DittoConstants.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/IndelUpdate.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSub.java (diff)
Commit 4786c9ff72ae1fe2b3b2f9dad4adab7e74315999 by Thomas Jaeckle
Issue #792: re-added "declared-acks" to DittoHeaderDefinition, but keep removed from DittoHeaders

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/gateway/util/src/main/java/org/eclipse/ditto/services/gateway/util/config/endpoints/HttpConfig.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebSocketRoute.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/common/DittoConstants.java (diff)
The file was modifiedservices/gateway/starter/src/main/resources/gateway.conf (diff)
The file was modifiedmodel/base/src/test/java/org/eclipse/ditto/model/base/headers/ImmutableDittoHeadersTest.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeaderDefinition.java (diff)
Commit 2790f0131cb491500845d4775ee8914d3591af25 by Thomas Jaeckle
Issue #792: log and respond with errors when subscribing to Ditto pubsub

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/DittoProtocolSub.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
Commit 5bfe682b82bc421c36204d4350de71bda10c51d1 by Thomas Jaeckle
Issue #792: post merge commit after merge from master
* applied refactorings from master to refactorings of this branch
* added connectionType to AbstractMappingProcessor
* used ThreadSafeDittoLoggingAdapter where TODOs were open

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/OutboundSignalToExternalMessageTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMappingProcessor.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/preauth/PreAuthenticatedAuthenticationProvider.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/TimeMeasuringAuthenticationProvider.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/PubUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/Publisher.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/EnableConnectionLogsStrategy.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/AuthenticationChain.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/HttpPushConfig.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/ResetConnectionLogsStrategy.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt5ConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtAuthenticationProvider.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractUpdater.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaPublisherActorFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/ResetConnectionMetricsStrategy.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
Commit 7dd91bac26e61f460bb6a146d09f7580fa0b92ed by Thomas Jaeckle
Issue #792: used ConnectivityInternalErrorException instead of Gateway one for ConnectionPersistenceActor

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
Commit 684eaf65a8755024148bcbf8d0e9017001f15864 by Thomas Jaeckle
fixed long open TODO: made ConnectivityStatus Jsonifiable

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/ConnectivityMappingStrategies.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectivityStatus.java (diff)
Commit 55fa1d84022ae789e3eaa91783fe05ac24e30e40 by Thomas Jaeckle
Issue #792: terminated session actor after subscribe to Ditto pubsub failed

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
Commit 018971f5d3c8abf6a5e7b93191e17f88a6b38ddc by Joel Bartelheimer
slight improvement on the wording in the policy base documentation

Signed-off-by: Joel Bartelheimer <joel.bartelheimer@bosch.io>
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-policy.md (diff)
Commit 725035db8091bb53ca82b48f23b78124f3d0a9e1 by Juergen Fickel
Issue #773: Handle ConcurrentModificationException at all places where it could be thrown to avoid disturbing actual service processes.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultAutoCloseableSlf4jLogger.java (diff)
Commit d6804b8a40b9a4ec9cd565703ec4db3de8ce9fc1 by Juergen Fickel
Issue #773: Use string for removal.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultAutoCloseableSlf4jLogger.java (diff)
Commit 6d37f36ad714d91ed51059382d9f00375e5e5975 by Yannic Klem
Adds blog post about the acknowledgement feature

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was addeddocumentation/src/main/resources/_posts/2020-10-06-end-2-end-acknowledgement.md
The file was modifieddocumentation/src/main/resources/_data/authors.yml (diff)
The file was modifieddocumentation/src/main/resources/_posts/2019-10-17-http-connectivity.md (diff)
Commit 6d6203d30aba67ef1b0f6f2e6ae26bb8b0254257 by Juergen Fickel
Issue #773: Javadoc of java.util.Map does not fully reveal where ConcurrentModificationExceptions are thrown, thus catching the exception for all interactions with 'localMdc' map.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultAutoCloseableSlf4jLogger.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DefaultDiagnosticLoggingAdapter.java (diff)
Commit f7e4c7efe329febb218bf25a77715ddc9c1ed085 by Yannic Klem
relax acknowledgement label regex

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabels.java (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/protocol-specification-topic.md (diff)
The file was modifieddocumentation/src/main/resources/jsonschema/protocol-envelope.json (diff)
Commit f8755b8100672ef8271259e569d3365ca87cec4c by Yannic Klem
fix unit tests

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedmodel/base/src/test/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelsTest.java (diff)
Commit 9dd0c9beaf4aceb38e94dd165df977cf2e672bca by Yannic Klem
replace since 1.3.0 with 1.4.0 for newly introduced AcknowledgementLabelNotUniqueException

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelNotUniqueException.java (diff)
Commit 7f79c5828ee49e2182ee4afb007712877f470e4b by Yannic Klem
completed javadoc todos

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMappingProcessor.java (diff)
Commit 775dc797783042a1975212e2e7b11ede6d24d74d by Yufei Cai
Add blog post about async client creation; update email of authors.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifieddocumentation/src/main/resources/_data/authors.yml (diff)
The file was addeddocumentation/src/main/resources/_posts/2020-10-08-asynchronous-client-creation.md
Commit 6eeb88bb40da70f30cd4432a059627a7d342123f by Yufei Cai
Update java client documentation.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifieddocumentation/src/main/resources/pages/ditto/client-sdk-java.md (diff)
Commit b463096a7f6dcef634adc348c0ed2a32b19d31ed by Thomas Jaeckle
Issue #792: review of e2e-acknowledgement blogpost:
* adjusted some formatting, e.g. heading levels, line breaks, adding toc
* inserted Scenario introduction
* added links to some more Ditto concepts/docs
* adjusted ack label regex in protocol-envelope.json and protocol-specification-topic.md

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifieddocumentation/src/main/resources/pages/ditto/protocol-specification-topic.md (diff)
The file was modifieddocumentation/src/main/resources/_posts/2020-10-06-end-2-end-acknowledgement.md (diff)
The file was modifieddocumentation/src/main/resources/jsonschema/protocol-envelope.json (diff)
Commit e95aca4748c104e8348943776253c7e9317dec7b by Yannic Klem
Fixed Mapping timers

* The overall timer for outbound signals was started but never stopped.
  Therefore the overall mapping timer for outbound signals did always
  finish with expiration.
* The overall timer for inbound signals was started for every mapper
  separately.
  The information about separate mappers can be found in the payload segment.
  Started the timer now once for all mappers for the overall segment

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessor.java (diff)
Commit 6ca2454e5f75be1a6d982019f59f34b1f378720b by Yannic Klem
log warning on expiration of mapping timer

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MappingTimer.java (diff)
Commit 4864b56d9e63eda4f22a034bb5260c1fcb30a3ab by Yannic Klem
Validate connection ID

* Since the connection ID is now essential part of declared and issued
  acknowledgements it is required, that it matches the regex of
  AcknowledgementLabels.

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/ConnectionLoggerRegistryTest.java (diff)
The file was modifiedsignals/events/connectivity/src/test/java/org/eclipse/ditto/signals/events/connectivity/ConnectionDeletedTest.java (diff)
The file was modifiedsignals/events/connectivity/src/test/java/org/eclipse/ditto/signals/events/connectivity/ConnectionOpenedTest.java (diff)
The file was addedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectionIdInvalidException.java
The file was modifiedsignals/events/connectivity/src/test/java/org/eclipse/ditto/signals/events/connectivity/ConnectionClosedTest.java (diff)
The file was addedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectionIdPatternValidator.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionSupervisorActor.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/entity/validation/AbstractPatternValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/stages/StagedCommand.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectionId.java (diff)
The file was modifiedmodel/connectivity/src/test/java/org/eclipse/ditto/model/connectivity/ConnectionIdTest.java (diff)
Commit df75b01cadaf2c3d7796a50cffa0877601b36d38 by Yannic Klem
adapt json example to described use case

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifieddocumentation/src/main/resources/_posts/2020-10-06-end-2-end-acknowledgement.md (diff)
Commit c5e3b3959b35c1ec2f0cefd42bdad819ec6e01d7 by Thomas Jaeckle
Issue #792: relaxed AcknowledgementLabel regex to be able to start with a placeholder
* lazily resolve the placeholder in connectivity, e.g. before declaring ACKs

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/DittoProtocolSubImpl.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabels.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabel.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidator.java (diff)
The file was modifiedmodel/base/src/test/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelsTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
Commit 0e20a94645676bd636b858eeac963f031e4de6e4 by Yufei Cai
Issue #792: concretize message mapping outcome..

Reason: Prepare for splitting the mapping and dispatching functions
of mapping processor actors.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessorTest.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingResultHandler.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMappingResultHandler.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingResultHandler.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessorActor.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MappingOutcome.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMappingProcessor.java (diff)
Commit b7b42b64cee1e069323045ca78257f4296e6df10 by Yufei Cai
Issue #792: remove self messaging of OutboudMappingProcessorActor; remove unnecessary parts of AbstractGraphActor; fix logger thread safety.

- Converted OutboundMappingProcessorActor's Receive into 2 stages
  to avoid self-messaging.

- Removed AbstractGraphActor.processMessageFlow.
  Renamed processedMessageSink to createSink.

- Use thread-safe loggers in AbstractGraphActor. The logger is used
  asynchronously because it is available inside a stream.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java (diff)
The file was modifiedservices/concierge/starter/src/main/java/org/eclipse/ditto/services/concierge/starter/actors/DispatcherActor.java (diff)
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/Contextual.java (diff)
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/EnforcementScheduler.java (diff)
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/EnforcerActor.java (diff)
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/AbstractEnforcement.java (diff)
The file was modifiedservices/concierge/enforcement/src/test/java/org/eclipse/ditto/services/concierge/enforcement/EnforcementSchedulerTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessorActor.java (diff)
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/AbstractEnforcerActor.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/controlflow/AbstractGraphActor.java (diff)
Commit c0ed9dd7d0a4fd5e0250940513add2d46924dc6a by Yufei Cai
Issue #792: separate inbound mapping processor actor into 2 actors.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessor.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingOutcomes.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundDispatchingActor.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MappingOutcome.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/DittoRuntimeExceptionToErrorResponseFunction.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActorTest.java (diff)
Commit ceeb09b79ab60ad023e0bb1ebe406ad87369a2e2 by Yufei Cai
Issue #792: delete duplicate serialVersionUID from ConnectionIdInvalidException.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectionIdInvalidException.java (diff)
Commit 5d595051a3e35636c4028945e3e3873ea279d8f6 by Yufei Cai
Issue #792: Fix consumer actor tests and a NullPointerException in AmqpConsumerActor.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundDispatchingActor.java (diff)
Commit a4868bbfaafe1eb05d33035bbafa0c85264f41c7 by Yufei Cai
Issue #792: document declared-acks.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifieddocumentation/src/main/resources/jsonschema/connection.json (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-acknowledgements.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-connections.md (diff)
Commit 35246e6e5c09c3595105cb9676a2b9bde8d7115a by Yufei Cai
Issue #792: allow WebSocketAuthorizationEnforcer to extend DittoHeaders.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebSocketAuthorizationEnforcer.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebSocketRoute.java (diff)
Commit c4e2d7cc5ccfabce185a385bae5fd413248191cc by Thomas Jaeckle
Issue #792: fixed wrong logic in checking for fully resolved ack labels in DittoProtocolSubImpl

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/DittoProtocolSubImpl.java (diff)
Commit 63fbc345be797b25bc1f38e1701bee2c30cf930f by Yufei Cai
Issue #792: Move algebraic datatype MappingOutcome to own package to enforce visibility.

Concrete implementations of MappingOutcome should not be visible elsewhere.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMappingProcessor.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mappingoutcome/MappingOutcome.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessor.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mappingoutcome/ErrorOutcome.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mappingoutcome/package-info.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingOutcomes.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mappingoutcome/DroppedOutcome.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MappingOutcome.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mappingoutcome/MappedOutcome.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundDispatchingActor.java (diff)
Commit 863ef102c9f023d56753d5e6b14bc58dd2df7565 by Thomas Jaeckle
Issue #792: fixed resolving target issued ack labels where they were not yet resolved

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mappingoutcome/MappingOutcome.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/SendingTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/Sending.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQPublisherActor.java (diff)
Commit 857cc81a09e079128cc605124ef522df0a2f9338 by Yannic Klem
ConnectionIdPlaceholder now only accepts ConnectionIds

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedmodel/placeholders/src/test/java/org/eclipse/ditto/model/placeholders/ImmutableExpressionResolverTest.java (diff)
The file was modifiedmodel/placeholders/src/test/java/org/eclipse/ditto/model/placeholders/ImmutableConnectionPlaceholderTest.java (diff)
The file was modifiedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/ImmutableConnectionIdPlaceholder.java (diff)
The file was modifiedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/ConnectionIdPlaceholder.java (diff)
Commit 21f206015cc3d199b5299d8cc086ae45408e6d02 by Thomas Jaeckle
Issue #792: review: add correlationId to logger where missing
* small cosmetic adjustments

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingOutcomes.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectionIdInvalidException.java (diff)
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/AbstractEnforcement.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundDispatchingActor.java (diff)
Commit acb1d6b0d78908b8f531132c9c01285b7dc59f62 by Yannic Klem
allow connection IDs with a lengt of 80

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabels.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectionId.java (diff)
Commit 0eec0ef681cbb5c82734d976d797a6ea6e5d3e23 by Thomas Jaeckle
Issue #792: doc review: fixed some typos

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-connections.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-acknowledgements.md (diff)
Commit 87de0c5c78650036bbf6d60421ce50f1eb802ae1 by Yannic Klem
fix unit test

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedmodel/base/src/test/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelsTest.java (diff)
Commit 205e732ef3c6c1251412de215efc579c5a63bcad by Yannic Klem
For live signals it's required to restore command connectivity headers

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundDispatchingActor.java (diff)
Commit e1cfeceecc147337ca8b72c2fbab61f51fd34005 by Thomas Jaeckle
added IoT WG community day status update slides

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifieddocumentation/src/main/resources/pages/ditto/presentations.md (diff)
The file was addeddocumentation/src/main/resources/slides/2020_10_19-eclipse-iot-wg-community-day/index.html
Commit bdf07f4b59d7d9abc0d44012931b406b38cd62f9 by Thomas Jaeckle
added some documentation about SSO with OpenID connect in the browser

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-auth.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/httpapi-sse.md (diff)
Commit 5582e65ab9da36a8cf9b9a9405d8f904f10e95bd by Thomas Jaeckle
Issue #792: make global/fallback timeouts for AMQP 1.0 connections configurable
* lower the default applied send timeout from 120seconds to 2seconds
* added unit tests for DefaultAmqp10Config

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultAmqp10Config.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/JMSConnectionHandlingActor.java (diff)
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/Amqp10Config.java (diff)
The file was addedservices/connectivity/messaging/src/test/resources/amqp10-test.conf
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/ConnectionBasedJmsConnectionFactory.java (diff)
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultAmqp10ConfigTest.java
Commit 74b6d70d0db57e35f80a78f42a7738f77c6632b5 by Thomas Jaeckle
Issue #792: exclude InboundDispatchingActor from receiving RetrieveAddressStatus messages

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
Commit 62c8e79f3457318f4ef49ff9d58527b903bfe3dc by Thomas Jaeckle
Issue #792: monitor successfully and failed publishing of outbound signals

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/ConnectionMonitorRegistry.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/SignalFilter.java (diff)
Commit c6ebcfe3fff384c334039658383d3b7066708dd5 by Thomas Jaeckle
Issue #792: fixed duplicated monitored failed publishing of outbound signals

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActor.java (diff)
Commit 6ef3aeed61d77fff0e64fbc17233fa3e26f342c1 by Thomas Jaeckle
Issue #792: fixed duplicated monitored success publishing of outbound signals (dependent on whether an auto issued ack is created or not)

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/Sending.java (diff)
Commit e49ac18a78938bf99ee5930a322de30fedeca45e by Thomas Jaeckle
Issue #792: fixed that a sent live message to a target containing an issued ack still contained that auto issued ack as "requested-acks" in its headers

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
Commit db325de3e548ce3fa288c3f48cf686085d5da767 by Thomas Jaeckle
Issue #792: undid monitoring publish success when no commandResponse (ack or live) was created when publishing a signal

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/Sending.java (diff)
Commit ff333d05c7e7cb9fdfbaf6fa9c220b13e1407022 by Thomas Jaeckle
Issue #792: fixed filtering of "requsted-acks" for connections without declared source acks

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
Commit 77c923526c5111e12e2753b8ee1fa336c4f6a5ac by Thomas Jaeckle
Issue #792: reverted removing issued acks from header as this breaks auto ack issuing

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
Commit 8108947e7e29f70380d55e01e7feb39b7532c6fd by Thomas Jaeckle
Issue #792: adjusted signal to be mapped to adaptable right before that step to filter out "issued acks" by targets from the "requested-acks" header

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMappingProcessor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActor.java (diff)
Commit 9350bba2af2e6ce56a4efd24088af572a3a8ef4b by Yufei Cai
Issue #792: Fix 500 for HTTP requests with invalid requested-acks.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/actors/HttpRequestActorTest.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/actors/AbstractHttpRequestActor.java (diff)
Commit 7aa67a72e84240791b9aa4456a25bd6414ba2057 by Yufei Cai
Issue #792: verify that query commands with ack requests do not cause redelivery.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorTest.java (diff)
Commit ee1e65f1e2d089c0d5ed89ba9fd4b3432bb51bd3 by Yufei Cai
Test header resetting in Ack.Agg.Actor and fix it.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/models/acks/src/test/java/org/eclipse/ditto/services/models/acks/AcknowledgementAggregatorActorTest.java (diff)
The file was modifiedservices/models/acks/src/main/java/org/eclipse/ditto/services/models/acks/AcknowledgementAggregatorActor.java (diff)
Commit 04368317b9381f7858b6689a3b4e986efd68ddc1 by Yufei Cai
Test recording of timer duration above 1s.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/metrics/src/test/java/org/eclipse/ditto/services/utils/metrics/instruments/timer/StoppedKamonTimerTest.java (diff)
Commit f122dc6519fb905a02212c0c6421a83a409d679b by Yufei Cai
Fix recording of timer duration above 1s.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/metrics/src/main/java/org/eclipse/ditto/services/utils/metrics/instruments/timer/StoppedKamonTimer.java (diff)
Commit f954ed2364a82d3d171b0e288e9826db0d26ae36 by noreply
updated slide with todays GH stars
The file was modifieddocumentation/src/main/resources/slides/2020_10_19-eclipse-iot-wg-community-day/index.html (diff)
Commit a8d21decb878f6a686f682920a3da389bb2325bb by Thomas Jaeckle
Issue #792: removed HTTP headers from being added to messages sent via HTTP POST
* they are preserved as DittoHeaders anyhow and this was a previous duplication which is unnecessary and error prone
* added unit test for removing Target "issued acks" from the "requested-acks" for published signals

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/things/MessagesRoute.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorTest.java (diff)
Commit 3094f920af3754d053829f2d157bd92caa6c8633 by Thomas Jaeckle
fixed using thread-safe loggers where we need to

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/operations/AbstractPersistenceOperationsActor.java (diff)
The file was modifiedservices/thingsearch/starter/src/main/java/org/eclipse/ditto/services/thingsearch/starter/actors/ThingsSearchCursor.java (diff)
The file was modifiedservices/thingsearch/starter/src/main/java/org/eclipse/ditto/services/thingsearch/starter/actors/SearchActor.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/RootRouteExceptionHandler.java (diff)
The file was modifiedservices/models/signalenrichment/src/main/java/org/eclipse/ditto/services/models/signalenrichment/CachingSignalEnrichmentFacade.java (diff)
Commit 9309a62c54d09c6a27f5cb4c587afb5090988b9f by Yufei Cai
Issue #792: ensure AcknowledgementLabelNotDeclaredException is mapped with the correct topic path information.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/DittoRuntimeExceptionToErrorResponseFunction.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundDispatchingActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessorActor.java (diff)
Commit 917c54d56b04c382da46f766f6ee9c635af40649 by Yannic Klem
provide more explicit information in AcknowledgementLabelInvalidException

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidator.java (diff)
Commit 6bdfc04a8f2f7e58c73b4bb8f8993d3b5582c825 by Yannic Klem
Replace exclamation marks with dots + reduce streaming chaing

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelNotDeclaredException.java (diff)
The file was modifiedsignals/acks/things/src/test/java/org/eclipse/ditto/signals/acks/things/ThingAcknowledgementJsonParserTest.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelNotUniqueException.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessor.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelInvalidException.java (diff)
Commit fdc3efad520799b1ecc2ea96847e3f125310c900 by Yannic Klem
Make base client actor more robust by catching DittoRuntimeExceptions
and just forward them to the outbound message mapping processor actor

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
Commit 06d24d4b68e5887c70dc9c5ffb4874105d8e373a by Yannic Klem
Implementing RequestedAcksValueValidator to fail fast

* it's no longer possible to instatiate DittoHeaders with invalid requested
  acks

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/HeaderValueValidators.java (diff)
The file was addedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/RequestedAcksValueValidator.java
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/actors/HttpRequestActorTest.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeaderDefinition.java (diff)
Commit a6849c068a1639737f41a22c7fd9d9a2657099f6 by Yufei Cai
Issue #792: reuse AbstractHttpRequestActor.handleDittoRuntimeException; remove unused imports in HttpRequestActorTest.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/actors/AbstractHttpRequestActor.java (diff)
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/actors/HttpRequestActorTest.java (diff)
Commit 615824a50409bb45f430c356ce2aa9a73e987181 by Thomas Jaeckle
Issue #792: fix metric counting/logging inconsistencies
* successful inbound Acknowledgements were not counted, only logged
* Acknowledgements were not counted/logged at all for "outgoing" (also responses) category
* don't count business errors (e.g. not found) as "source consumed" failure as the consumption did work and already was counted as a success in that same category
* successful Acknowledgements for MQTT consumers were not counted at all
* publishedMonitor was reused as droppedMonitor in BasePublisherActor.getSendingContextForTarget

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/AbstractMqttConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/Sending.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/MetricType.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/DefaultConnectionMonitorRegistry.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/SendingTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/Dropped.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/DroppedTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/ConnectionMonitor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/ConnectionMonitorRegistry.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActor.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/LogType.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/metrics/ConnectivityCounterRegistry.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/ConnectionLoggerRegistry.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQConsumerActor.java (diff)
Commit 891f10acce89cd54d1124d7e4fdf6cf9508166b0 by Thomas Jaeckle
Issue #792: removed unused method

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseConsumerActor.java (diff)
Commit 9df2a68cb537e077196674f1d176577e0aa155a0 by Joel Bartelheimer
Wrap sending the Amqp messages in a stream with a preceding queue/buffer

The queue infront of the amqp-send-msg stage, drops messages if the queue is full. This prevent an overflow of the actor mailbox if the consumer isn't fast enough or doesn't consume at all.

Signed-off-by: Joel Bartelheimer <joel.bartelheimer@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultAmqp10Config.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/Amqp10Config.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpMessageContext.java
Commit f3cdc93648d33f8f7bbb7dd036103b98a5cffa95 by Yannic Klem
Make clear that WebSockets are not meant to be used for horizontal scaling
or high availability scenarios.

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-acknowledgements.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/httpapi-protocol-bindings-websocket.md (diff)
Commit 77ccab6bda314400adc6e5cdfccd16c65ff1e27e by Thomas Jaeckle
Issue #792: fixed/adjusted acknowledgement logging texts for connectionLogger

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/AbstractMqttConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/ConnectionLoggerFactory.java (diff)
Commit 47ed1d859524f00926ee2fe9b9a06d607edbc7b5 by Thomas Jaeckle
fixes #844: "location" header was not read when provided by external headers

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedprotocol-adapter/src/test/java/org/eclipse/ditto/protocoladapter/HeaderEntryFiltersTest.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeaderDefinition.java (diff)
Commit 7e8f782b56134bca2bb3534c818352b3f03a71dd by Thomas Jaeckle
Issue #792: added MessageMapper id to connectionLog statements about mapped/dropped (and error)
* in order to find out which mapping (when having multiple mappers) succeeded, which messages were dropped by which mapper and which failed

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mappingoutcome/ErrorOutcome.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/ConnectionLoggerFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mappingoutcome/DroppedOutcome.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mappingoutcome/MappingOutcome.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundDispatchingActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mappingoutcome/MappedOutcome.java (diff)
Commit 6f6cd2c809c7e1012ac999561cacbd834cb1cb68 by Thomas Jaeckle
Issue #792: fixed mapping texts which had the wrong direction

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundDispatchingActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/ConnectionLoggerFactory.java (diff)
Commit 688945827345adbff861ca40e5b3b72fbf7de90f by Yufei Cai
Make protocol of OAuth providers configurable.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/gateway/util/src/test/resources/oauth-test.conf (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/DittoPublicKeyProvider.java (diff)
The file was modifiedservices/gateway/util/src/main/java/org/eclipse/ditto/services/gateway/util/config/security/OAuthConfig.java (diff)
The file was modifiedservices/gateway/util/src/test/java/org/eclipse/ditto/services/gateway/util/config/security/DefaultOAuthConfigTest.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtSubjectIssuersConfig.java (diff)
The file was modifiedservices/gateway/starter/src/main/resources/gateway.conf (diff)
The file was modifiedservices/gateway/starter/src/main/resources/gateway-dev.conf (diff)
The file was modifiedservices/gateway/util/src/main/java/org/eclipse/ditto/services/gateway/util/config/security/DefaultOAuthConfig.java (diff)
Commit e7e6a605d4976b428dd5a86a7153e971e409e15d by Yannic Klem
Set response-required to false for responses and events

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/modify/CreateThingLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/actors/HttpRequestActorTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/query/RetrieveAttributesLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedsignals/events/things/src/main/java/org/eclipse/ditto/signals/events/things/AbstractThingEvent.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/NormalizedMessageMapperTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/query/RetrieveFeatureDefinitionLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedsignals/acks/base/src/main/java/org/eclipse/ditto/signals/acks/base/ImmutableAcknowledgements.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/query/RetrieveThingsLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/actors/HttpRequestActorHeaderInteractionTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/query/RetrieveFeaturePropertyLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedprotocol-adapter/src/test/java/org/eclipse/ditto/protocoladapter/acknowledgements/AcknowledgementsAdapterTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/modify/ModifyAttributesLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/modify/ModifyAttributeLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedservices/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/QueryThingsPerRequestActor.java (diff)
The file was modifiedsignals/acks/things/src/test/java/org/eclipse/ditto/signals/acks/things/ThingAcknowledgementsFactoryTest.java (diff)
The file was modifiedservices/models/acks/src/test/java/org/eclipse/ditto/services/models/acks/AcknowledgementAggregatorActorTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturePropertyLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/query/RetrieveFeatureLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedprotocol-adapter/src/test/java/org/eclipse/ditto/protocoladapter/DittoProtocolAdapterTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeatureDefinitionLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeatureLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/query/RetrieveAttributeLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedsignals/acks/base/src/main/java/org/eclipse/ditto/signals/acks/base/ImmutableAcknowledgement.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/modify/ModifyThingLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/modify/DeleteAttributeLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturePropertiesLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/routes/whoami/WhoamiResponseTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/modify/DeleteAttributesLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/AbstractCommandResponse.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeatureLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturesLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/query/RetrieveFeaturePropertiesLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/query/RetrieveFeaturesLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedsignals/acks/base/src/test/java/org/eclipse/ditto/signals/acks/base/ImmutableAcknowledgementTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeatureDefinitionLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedsignals/acks/base/src/test/java/org/eclipse/ditto/signals/acks/base/ImmutableAcknowledgementsTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/query/RetrieveThingLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturePropertiesLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturePropertyLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/modify/DeleteThingLiveCommandAnswerBuilderImplTest.java (diff)
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/actors/AbstractHttpRequestActorTest.java (diff)
The file was modifiedservices/gateway/proxy/src/test/java/org/eclipse/ditto/services/gateway/proxy/actors/QueryThingsPerRequestActorTest.java (diff)
The file was modifiedsignals/acks/things/src/test/java/org/eclipse/ditto/signals/acks/things/ThingAcknowledgementFactoryTest.java (diff)
The file was modifiedsignals/commands/live/src/test/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturesLiveCommandAnswerBuilderImplTest.java (diff)
Commit e974b6f1f3856a9241eb348e47b8ac5026c1041e by Thomas Jaeckle
updated CQs

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedlegal/3rd-party-dependencies/cqs.md (diff)
The file was modifiedlegal/3rd-party-dependencies/compile.txt (diff)
The file was modifiedbom/pom.xml (diff)
Commit 5a31357c0e661405e5f9f4b38d1bb65444336aab by Yannic Klem
Provide second constructor to allow providing a non static category for
validation purposes

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/AbstractCommand.java (diff)
Commit 23935fc795e0863eb5e699e2ae448180f78998e3 by Thomas Jaeckle
Issue #792: documentation review: added "warning" sections for clarifying that the WS is not intended to be used as scaling out or doing HA

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-enrichment.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-connections.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/client-sdk-java.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/httpapi-protocol-bindings-websocket.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/httpapi-sse.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-acknowledgements.md (diff)
Commit 39b3ad00c76c6c82c4337b72c014085a02e80e06 by Thomas Jaeckle
Issue #792: review: restore DittoHeaders on a best effort basis in InboundMappingProcessor in order to retain e.g. "reply-to" required to find out where to send an error response to
* added missing @since javadoc; removed unused method in InboundMappingProcessorActor

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessorActor.java (diff)
The file was modifiedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/ImmutableExpressionResolver.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/HeaderValueValidators.java (diff)
Commit 13c0aa9c80c0b8c21bfd004b9ea2c2a9d727b47e by Yufei Cai
Issue #792: Review: Add argument matchers to SendingTest.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/SendingTest.java (diff)
Commit a0a487f1046c03d0880adda7a6687051e5089661 by Yufei Cai
Add StoppedKamonTimer.getElapsedNano; fix logging.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/metrics/src/main/java/org/eclipse/ditto/services/utils/metrics/instruments/timer/StoppedKamonTimer.java (diff)
Commit 3bdcff418393f19a81b7eea4977abcef7330e905 by Thomas Jaeckle
Issue #792: fixed merging of "best effort headers" with already existing DittoHeaders

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessor.java (diff)
Commit 83481d092b5a8d7303331dd6fcc0abb678b018ad by Thomas Jaeckle
adjusted all DittoRuntimeExceptions to overwrite setDittoHeaders(DittoHeaders) method in order to preserve the type of the exception; unfortunately this can't be fixed without major changes to DittoRuntimeException

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedmodel/messages/src/main/java/org/eclipse/ditto/model/messages/MessageTimeoutException.java (diff)
The file was modifiedmodel/things/src/main/java/org/eclipse/ditto/model/things/DefinitionIdentifierInvalidException.java (diff)
The file was modifiedsignals/commands/thingsearch/src/main/java/org/eclipse/ditto/signals/commands/thingsearch/exceptions/SubscriptionTimeoutException.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/entity/id/NamespacedEntityIdInvalidException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayPlaceholderReferenceUnknownFieldException.java (diff)
The file was modifiedmodel/namespaces/src/main/java/org/eclipse/ditto/model/namespaces/NamespaceBlockedException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayWebsocketSessionClosedException.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelNotDeclaredException.java (diff)
The file was modifiedmodel/policies/src/main/java/org/eclipse/ditto/model/policies/PolicyIdInvalidException.java (diff)
The file was modifiedsignals/commands/connectivity/src/main/java/org/eclipse/ditto/signals/commands/connectivity/exceptions/ConnectionFailedException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/ThingNotAccessibleException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/PolicyEntryModificationInvalidException.java (diff)
The file was modifiedsignals/commands/thingsearch/src/main/java/org/eclipse/ditto/signals/commands/thingsearch/exceptions/SubscriptionNotFoundException.java (diff)
The file was modifiedmodel/policies/src/main/java/org/eclipse/ditto/model/policies/SubjectIdInvalidException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/SubjectsNotModifiableException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/SubjectsNotAccessibleException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/FeatureDefinitionNotModifiableException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/FeaturesNotAccessibleException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/ThingUnavailableException.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/UnknownChannelException.java (diff)
The file was modifiedmodel/things/src/main/java/org/eclipse/ditto/model/things/FeatureDefinitionEmptyException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/PolicyModificationInvalidException.java (diff)
The file was modifiedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/PlaceholderFunctionUnknownException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/PolicyEntryNotModifiableException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayTimeoutInvalidException.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/UnknownCommandException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/CommandNotSupportedException.java (diff)
The file was modifiedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/PlaceholderFunctionTooComplexException.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/UnknownSignalException.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/exceptions/UnsupportedMediaTypeException.java (diff)
The file was modifiedsignals/commands/thingsearch/src/main/java/org/eclipse/ditto/signals/commands/thingsearch/exceptions/InvalidOptionException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/ThingTooManyModifyingRequestsException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayPlaceholderNotResolvableException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/PolicyNotModifiableException.java (diff)
The file was modifiedsignals/commands/connectivity/src/main/java/org/eclipse/ditto/signals/commands/connectivity/exceptions/ConnectionSignalIllegalException.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/UnknownCommandResponseException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/PolicyNotAccessibleException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/ThingDefinitionNotModifiableException.java (diff)
The file was modifiedmodel/jwt/src/main/java/org/eclipse/ditto/model/jwt/JwtAudienceInvalidException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayJwtIssuerNotSupportedException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/FeatureDefinitionNotAccessibleException.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/UnknownTopicPathException.java (diff)
The file was modifiedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/PlaceholderFunctionSignatureInvalidException.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/UnknownPathException.java (diff)
The file was modifiedmodel/messages/src/main/java/org/eclipse/ditto/model/messages/FeatureIdInvalidException.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectionSignalIdEnforcementFailedException.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/TopicParseException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/AclNotAccessibleException.java (diff)
The file was modifiedsignals/commands/connectivity/src/main/java/org/eclipse/ditto/signals/commands/connectivity/exceptions/ConnectionUnavailableException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/PolicyIdNotModifiableException.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectionConfigurationInvalidException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/PolicyNotAllowedException.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/MessageSendingFailedException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/FeatureNotAccessibleException.java (diff)
The file was modifiedmodel/things/src/main/java/org/eclipse/ditto/model/things/AclNotAllowedException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/AttributesNotAccessibleException.java (diff)
The file was modifiedsignals/commands/thingsearch/src/main/java/org/eclipse/ditto/signals/commands/thingsearch/exceptions/InvalidNamespacesException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayServiceTooManyRequestsException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/SubjectNotModifiableException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/FeaturesNotModifiableException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/AttributePointerInvalidException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayInternalErrorException.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/exceptions/DittoHeaderInvalidException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/FeatureNotModifiableException.java (diff)
The file was modifiedmodel/things/src/main/java/org/eclipse/ditto/model/things/ThingTooLargeException.java (diff)
The file was modifiedmodel/messages/src/main/java/org/eclipse/ditto/model/messages/MessagePayloadSizeTooLargeException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/MissingThingIdsException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayWebsocketSessionExpiredException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/EventSendNotAllowedException.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/exceptions/DittoHeadersTooLargeException.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectionUriInvalidException.java (diff)
The file was modifiedmodel/messages/src/main/java/org/eclipse/ditto/model/messages/ThingIdInvalidException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/PoliciesConflictingException.java (diff)
The file was modifiedsignals/commands/connectivity/src/main/java/org/eclipse/ditto/signals/commands/connectivity/exceptions/ConnectionIdNotExplicitlySettableException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/PolicyEntryNotAccessibleException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/ThingNotModifiableException.java (diff)
The file was modifiedsignals/acks/base/src/main/java/org/eclipse/ditto/signals/acks/base/AcknowledgementRequestDuplicateCorrelationIdException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/ThingNotCreatableException.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/exceptions/TooManyRequestsException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/ThingConflictException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/AclNotModifiableException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayMethodNotAllowedException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayPlaceholderReferenceNotSupportedException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/PolicyPreconditionFailedException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/PolicyInvalidException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/ThingDefinitionNotAccessibleException.java (diff)
The file was modifiedmodel/messages/src/main/java/org/eclipse/ditto/model/messages/MessageSendNotAllowedException.java (diff)
The file was modifiedmodel/messages/src/main/java/org/eclipse/ditto/model/messages/SubjectInvalidException.java (diff)
The file was modifiedmodel/things/src/main/java/org/eclipse/ditto/model/things/AclEntryInvalidException.java (diff)
The file was modifiedmodel/messages/src/main/java/org/eclipse/ditto/model/messages/TimeoutInvalidException.java (diff)
The file was modifiedmodel/things/src/main/java/org/eclipse/ditto/model/things/PolicyIdMissingException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/PolicyIdNotExplicitlySettableException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/AttributeNotAccessibleException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayAuthenticationProviderUnavailableException.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/exceptions/InvalidRqlExpressionException.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/exceptions/TimeoutInvalidException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/AttributeNotModifiableException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayQueryTimeExceededException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/FeaturePropertiesNotAccessibleException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/PolicyTooManyModifyingRequestsException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/FeaturePropertiesNotModifiableException.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/UnknownEventException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/ResourceNotModifiableException.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectivityInternalErrorException.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/MessageMappingFailedException.java (diff)
The file was modifiedsignals/base/src/main/java/org/eclipse/ditto/signals/base/JsonTypeNotParsableException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/ResourceNotAccessibleException.java (diff)
The file was modifiedmodel/messages/src/main/java/org/eclipse/ditto/model/messages/MessageFormatInvalidException.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelInvalidException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/PolicyUnavailableException.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/PublicKeyProviderUnavailableException.java (diff)
The file was modifiedsignals/commands/thingsearch/src/main/java/org/eclipse/ditto/signals/commands/thingsearch/exceptions/SubscriptionProtocolErrorException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/ThingNotDeletableException.java (diff)
The file was modifiedmodel/things/src/main/java/org/eclipse/ditto/model/things/ThingIdInvalidException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayServiceTimeoutException.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectionIdInvalidException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/AclModificationInvalidException.java (diff)
The file was modifiedmodel/jwt/src/main/java/org/eclipse/ditto/model/jwt/JwtInvalidException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/FeaturePropertyNotModifiableException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/ThingPreconditionFailedException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/ThingPreconditionNotModifiedException.java (diff)
The file was modifiedmodel/things/src/main/java/org/eclipse/ditto/model/things/AclInvalidException.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/exceptions/SignalEnrichmentFailedException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/ResourcesNotModifiableException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/PolicyIdNotAccessibleException.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/MessageMapperConfigurationInvalidException.java (diff)
The file was modifiedsignals/commands/connectivity/src/main/java/org/eclipse/ditto/signals/commands/connectivity/exceptions/ConnectionNotAccessibleException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/ResourcesNotAccessibleException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayAuthenticationFailedException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/FeaturePropertyNotAccessibleException.java (diff)
The file was modifiedmodel/policies/src/main/java/org/eclipse/ditto/model/policies/PolicyTooLargeException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/AttributesNotModifiableException.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelNotUniqueException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/PolicyIdNotAllowedException.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/MessageMapperConfigurationFailedException.java (diff)
The file was modifiedmodel/messages/src/main/java/org/eclipse/ditto/model/messages/AuthorizationSubjectBlockedException.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/exceptions/DittoRuntimeException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/SubjectNotAccessibleException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayDuplicateHeaderException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayServiceUnavailableException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/PolicyConflictException.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/DittoAcknowledgementLabelExternalUseForbiddenException.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementRequestParseException.java (diff)
The file was modifiedsignals/acks/base/src/main/java/org/eclipse/ditto/signals/acks/base/AcknowledgementRequestTimeoutException.java (diff)
The file was modifiedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/UnresolvedPlaceholderException.java (diff)
The file was modifiedsignals/commands/connectivity/src/main/java/org/eclipse/ditto/signals/commands/connectivity/exceptions/ConnectionTimeoutException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayCommandTimeoutException.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/CommandHeaderInvalidException.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/exceptions/PolicyPreconditionNotModifiedException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/exceptions/ThingIdNotExplicitlySettableException.java (diff)
The file was modifiedsignals/acks/base/src/main/java/org/eclipse/ditto/signals/acks/base/AcknowledgementCorrelationIdMissingException.java (diff)
The file was modifiedsignals/commands/connectivity/src/main/java/org/eclipse/ditto/signals/commands/connectivity/exceptions/ConnectionConflictException.java (diff)
The file was modifiedmodel/policies/src/main/java/org/eclipse/ditto/model/policies/PolicyEntryInvalidException.java (diff)
Commit 007b8faa0ce1febc18268e1242374e531c252811 by Thomas Jaeckle
#844: fixed header case sensitivity for CheckExternalFilter used in HeaderTranslator
* added test ensuring that case is not sensitive (test failed before adjustment)
* undid making "www-authenticate" readable from external headers

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeaderDefinition.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/CheckExternalFilter.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/ReadJsonArrayHeadersFilter.java (diff)
The file was modifiedprotocol-adapter/src/test/java/org/eclipse/ditto/protocoladapter/CheckExternalFilterTest.java (diff)
Commit fd6c36ccb620545ff33f1ea32188c453355b0bc2 by Thomas Jaeckle
Issue #792: added best effort fallback for determining entity id for exceptions which did not yet pass the protocol adapter

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/DittoRuntimeExceptionToErrorResponseFunction.java (diff)
Commit 653ec7fdd497df5fe25df4feb8382ade3043c71b by Johannes Schneider
close streaming session when an invalid jwt is provided

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
The file was addedservices/gateway/streaming/src/test/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActorTest.java
Commit 3355fea7df74cc033ed1e5961e0f03c010180e87 by Joel Bartelheimer
Add tests for new introduced publisher-queue

also adapted the config to the introduced properties

Signed-off-by: Joel Bartelheimer <joel.bartelheimer@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActorTest.java (diff)
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/Amqp10Config.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/resources/test.conf (diff)
Commit 9fe1803dcaeb32a8b3f7b35250714df080848737 by Yannic Klem
fix javadoc

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubSupervisor.java (diff)
Commit 4f788d729ca9a1ed24efe7fcef9c9788c00914c2 by Yannic Klem
code wrapping was required. added closing bracket

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubSupervisor.java (diff)
Commit 61c87aff2106e11e5c383af453c22312d4dffe91 by Thomas Jaeckle
Issue #792: adjusted blogpost date about acks to today

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was addeddocumentation/src/main/resources/_posts/2020-10-23-end-2-end-acknowledgement.md
The file was removeddocumentation/src/main/resources/_posts/2020-10-06-end-2-end-acknowledgement.md
Commit 030c1820cd419f59ae28d6b1e839c059b4835b57 by Joel Bartelheimer
Add JavaDocs and some minor refactorings of the newly integrated pusblisher-queue

Signed-off-by: Joel Bartelheimer <joel.bartelheimer@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpMessageContext.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultAmqp10Config.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/Amqp10Config.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActor.java (diff)
Commit 70d81edc709e6b7467dd51c8ccebb87bea93e1a6 by Yannic Klem
Introduce SilentlyFailingRevocationChecker

* This checker catches failures during revocation checking and logs them
  in a connection logger

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/MockHiveMqtt3ClientFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactoryTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/SSLContextCreator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/ConnectionLogger.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/JmsConnectionHandlingActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractBaseClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/JmsConnectionFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/JMSConnectionHandlingActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/TrustManagerFactoryFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitConnectionFactoryFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/ConnectionBasedRabbitConnectionFactoryFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/AbstractSSLContextTest.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/SilentlyFailingRevocationChecker.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqttClientFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/DittoTrustManagerFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/ConnectionBasedJmsConnectionFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/AbstractMqttClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/DefaultHiveMqtt3ClientFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/DefaultHiveMqtt5ClientFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/AbstractHiveMqttClientFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/CustomSSLContextTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/SSLContextCreatorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/DefaultHttpPushFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/MockHiveMqtt5ClientFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherErrorTest.java (diff)
Commit 67a1272a26cd13c93c5aa35af9790a79f7b8be6e by Joel Bartelheimer
Add the new config values to the new config tests, which were introduced in the last merge

Signed-off-by: Joel Bartelheimer <joel.bartelheimer@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultAmqp10ConfigTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultAmqp10Config.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/resources/amqp10-test.conf (diff)
Commit 71526892e43f13158ca47f344042394cd5bcff61 by Yufei Cai
AmqpPublisherActorTest: Prevent test failure due to low timeout.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/resources/test.conf (diff)
Commit 3d089e333ca4f5dc54798c8a3432517f19f465d8 by Yufei Cai
Review: AmqpPublisherActor: move non-thread-safe producer lookup to the actor's thread; format code; fix comment; do not request ack for the congesting messages in AmqpPublisherActorTest.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActor.java (diff)
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActorTest.java (diff)
Commit cf14a6dc9fd8a5d55e1e6901b314e57fb1b82882 by Johannes Schneider
formatting

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modifiedservices/gateway/streaming/src/test/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActorTest.java (diff)
Commit abf112a230273386203d3397ce57cc5c21ae3ab3 by Johannes Schneider
fix test after merge

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modifiedservices/gateway/streaming/src/test/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActorTest.java (diff)
Commit d22919bb42142f0266f6527ccef90f7d881d7a25 by Yannic Klem
Deprecate topic:entityId placeholder and introduce topic:entityName placeholder

* entityId placeholder was not named correctly. It was resolved with the
  name of an entity and not the complete ID. Therefore a new placeholder
  entityName is introduced which reflects correctly what it means.

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedmodel/placeholders/src/test/java/org/eclipse/ditto/model/placeholders/ImmutableExpressionResolverTest.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/ImmutableTopicPath.java (diff)
The file was modifiedmodel/placeholders/src/main/java/org/eclipse/ditto/model/placeholders/ImmutableTopicPathPlaceholder.java (diff)
The file was modifiedmodel/placeholders/src/test/java/org/eclipse/ditto/model/placeholders/ImmutableTopicPathPlaceholderTest.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/TopicPath.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/ImmutableTopicPathBuilder.java (diff)
Commit be1edc1daa64a90537221486feba8542e117bfb3 by Yannic Klem
document new placeholder topic:entityName and deprecate topic:entityId

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-placeholders.md (diff)
Commit a9862891269119159c49371c23d250a770d38f7b by Yannic Klem
Log handling of http response for http forwarding connection in connection logs

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherActor.java (diff)
Commit 7a4b8c43bd7174afb2e384f9903db5d0879018f6 by Yufei Cai
Make revocation check optional at the trust-manager level.

It is not possible to perform revocation check and not throw
any exception inside an PKIXRevocationCheckerbecause the
certificate validator does not initialize non-default
revocation checkers, which causes NullPointerException
on each check.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/SilentlyFailingRevocationChecker.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/DittoTrustManagerFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/SSLContextCreator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/DittoTrustManager.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/NoRevocationChecker.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/TrustManagerFactoryFactory.java (diff)
Commit 6af1af963d62922101bb5c3022d2d3089aad5391 by Yannic Klem
make connection logger a field of BasePublisherActor

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherActor.java (diff)
Commit 8bf97083116b6b1364dccf5bf1e518b5b72432fa by Yannic Klem
Make connectionLogger field in DittoTrustManager non nullable

* Adapt test code to properly mock the parameter

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/DittoTrustManager.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/SSLContextCreator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/DittoTrustManagerFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractBaseClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/CustomSSLContextTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/SSLContextCreatorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/AbstractSSLContextTest.java (diff)
Commit 05c727d6bc996a8caf18e8754d915e582772fb74 by Yannic Klem
Make hostname non nullable since it was only null in test cases

* adapted test cases to not call methods with null hostname

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/AbstractSSLContextTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/DittoTrustManagerFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/DittoTrustManager.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/SSLContextCreator.java (diff)
Commit b8f6489a54208f93d0f69d08595b42dd11401bc3 by Yannic Klem
delegateWithoutRevocationCheck can never be null

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/DittoTrustManager.java (diff)
Commit 4d29e10a511dec8347b64841b4156eb358ab27f7 by Yufei Cai
Add 1.4.0 release notes.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was addeddocumentation/src/main/resources/_posts/2020-10-28-release-announcement-140.md
The file was modifieddocumentation/src/main/resources/_data/sidebars/ditto_sidebar.yml (diff)
The file was addeddocumentation/src/main/resources/pages/ditto/release_notes_140.md