Skip to content
[Jenkins]Jenkins
log in

Changes

Summary

  1. Add connectivity announcements for when a connection was opened or closed (details)
  2. Add connectivity announcements to the ditto protocol (details)
  3. Also resolve connectivity signals from Adaptables (details)
  4. Add connection announcements to the Topic (details)
  5. Add connection announcements to the signal filter (details)
  6. Don't subscribe to internal Ditto PubSub for connectivity announcements as they are only sent outwards (details)
  7. added Ditto 2.0 to documentation version picker (details)
  8. activate binary compatibility check to version 2.0.0 (details)
  9. added Ditto 2.0.x to SECURITY.md (details)
  10. restructure kubernetes deployment Readmes; (details)
  11. bump nginx version to 1.20-alpine; (details)
  12. #1052: Fix typo (details)
  13. Send connection announcement after opening and before closing a connection (details)
  14. Close connections when shutting down the the cluster (which will trigger sending a close announcement) (details)
  15. Close connection before deleting it (which will automatically send a connection announcement) (details)
  16. fix ErrorHandlingActorTest (details)
  17. Avoids throwing exceptions in ditto metrics and return more or less (details)
  18. fixed typo in 2.0 announcement (details)
  19. only log warning if already stopped timer should be stopped (details)
  20. fixed parallelism of search-updater using "flatMapMerge" (details)
  21. added custom dispatchers for flatMapMerge() with async() usage in (details)
  22. fixed EnforcementFlowTest (details)
  23. added missing dispatcher to search test config (details)
  24. fixed SearchActorIT (details)
  25. fixed that Policy Error responses in WS contained wrong topic path (details)
  26. #1052: validate that connection announcements can only be used with client count 1 (details)
  27. fixed default config of retrieval.parallelism to be a factor of 2 (details)
  28. removed .withAttributes(Attributes.inputBuffer from search-updater-flows (details)
  29. uncomment resources config for all services; (details)
  30. #1052: Add documentation for connection announcement (details)
  31. #1052: mention connection announcements in protocol-specification.md (details)
  32. relax mqtt validation for source header mappings (details)
  33. Fixed missing publish metrics for published messages without (details)
  34. 1052: fix wording for connection announcement (details)
  35. fixed that for commands requesting "search-persisted" the wrong write concern was used (details)
  36. added "docker pulls" badge to readme (details)
  37. Issue #1060: add test cases for Azure and AWS signing processes (details)
  38. made AckUpdater work with ddata sharding (details)
  39. Issue #1060: add azure monitor request signing (details)
  40. Issue #1060: Add AwsRequestSigning; switch signing timestamp formatter to DateTimeFormatter; add TODO in AbstractBaseClientActorTest (details)
  41. Issue #1060: Add HmacCredentials. (details)
  42. Fix broken links in installation-operating.md (details)
  43. Implement basic structure for kafka consumers (details)
  44. added logging a type hint to AbstractEnforcement successful enforcement (details)
  45. put log statements with debug content to DEBUG level (details)
  46. Added validation for source address and target header mappings (details)
  47. Issue #1060: add dynamic loading of HTTP request signing algorithms. (details)
  48. review: fixed comment which still pointed to outdated enum name (details)
  49. Handle exceptions in MessageProcessor to avoid exceptions in KafkaStreams (details)
  50. Make move the logic again to a transformer (details)
  51. use var keyword; (details)
  52. Use correct branch names to access them in the map (details)
  53. use min interval from backoffConfig to create RestartSettings; (details)
  54. Issue #1060: Only validate certificate for client certificate credentials in the absence of server certificate; do not throw UnsupportedOperationsException in other cases. (details)
  55. move start of stream to preStart hook (details)
  56. move initialisation of logger back to top (details)
  57. Use scalas Either to avoid using generic Object as return type (details)
  58. WIP: switch to akka-stream-kafka (details)
  59. fix MQTT protocol level acknowledgements (details)
  60. fixed applying "eventLoopThreads" option (details)
  61. #1052: edit documentation for topic path of connection announcements (details)
  62. applied manual reconnect for MQTT connections (details)
  63. make it possible to write logs to Logstash endpoint; (details)
  64. add logstash-logback-encoder and janino dependency; (details)
  65. add exclude for shade plugin; (details)
  66. add volume and volumeMounts to access ditto log files; (details)
  67. #1052 correct year in licence header (details)
  68. removed duplicate check for empty failed responses; (details)
  69. add missing volumeMounts; (details)
  70. add logging possibilities to installation-operating.md; (details)
  71. review: prefixed all logging related environment variables with `DITTO_LOGGING_` (details)
  72. fixed logback XML error (details)
  73. added Ditto 2.0.1 release notes (details)
  74. Issue #1060: Support GET method in HTTP connections; support x-amz-content-sha256 in AwsRequestSigning. (details)
  75. added a new introduction slide-deck for Eclipse Ditto (details)
  76. Issue #1060: Fix xAmzContentSha256 field name; log outgoing HTTP request on DEBUG. (details)
  77. Remove not needed hyphen in ditto-cluster.yaml (details)
  78. Surround env value with double quotation marks (details)
  79. Fix command to start ditto with another version (details)
  80. Issue #1060: Log signed requests on DEBUG level. (details)
  81. Connectivity: Improve debug log for incoming messages. (details)
  82. Fix missing placeholder in debug log. (details)
  83. #586 add configuration for kafka consumer, add migration notes for changed kafka configuration (details)
  84. Fix parameter passing to payload mapper when topic path contains no channel (details)
  85. Append signature topics with undefined channel (details)
  86. add logging in case of errors; (details)
  87. make ThingPersistenceActorMailbox size configurable via env variable; (details)
  88. #1052: correctly deserialize and serialize the parts of a topic for the "none" channel (policies and connections) in the JavaScript mappings (details)
  89. #1052: add unit tests verifying correct behaviour of the Ditto JavaScript helper functions for policy and connection announcements (details)
  90. Issue #1060: Add missing header for AWS request signing. (details)
  91. add debug log for dropped signals, if target address can not be resolved; (details)
  92. Issue #1060: render auth parameters without quotes in AwsRequestSigning. (details)
  93. split log for targets and replayTarget into separate statements; (details)
  94. Issue #1060: Fix AwsRequestSigningTest. (details)
  95. #586 use alpakka kafka also for sending messages to kafka cluster, remove dependencies to kafka-clients and kafka-streams, adapt service config and tests (details)
  96. Issue #1060: Add reserved HTTP header "http.query" to replace the query string. (details)
  97. #1060 fix behaviour on empty path. Add unit tests (details)
  98. Issue #1060: Fix double-appending of "/" to empty paths in AwsRequestSigning. (details)
  99. Issue #1060: Fix AwsRequestSigningTest again. (details)
  100. bump nginx version in docker-compose.yml to 1.20-alpine; (details)
  101. add initContainer for nginx to wait for gateway to be available before start up; (details)
  102. remove link to /apidoc/1 in index.html in docker and kubernetes; (details)
  103. add link to resource quota docu; (details)
  104. Issue #1060: Add HMAC credentials to connection schema. (details)
  105. Issue #1060: Document HMAC request signing. (details)
  106. #586 add throttling config for kafka consumers, resolve defaults for akka.kafka.consumer and akka.kafka.producer (details)
  107. Issue #1060: Validate connections with HMAC credentials. (details)
  108. #1060: Documentation: add GET as new http verb for http1.1 connections (details)
  109. #586 add defaults from reference.conf manually (temp. solution) (details)
  110. #1060: add documentation entry for "http.query" header mapping (details)
  111. #586 update to akka 2.6.14 (details)
  112. #586 configure shade plugin to append version.conf files for connectivity service (akka kafka contains another version.conf) (details)
  113. #586 add immutability test and reduced logging for message transformer (details)
  114. #1073 reduce logging of JWT parsing/validation errors to not contain stacktrace (details)
  115. #586 use defaults from reference.conf (details)
  116. omit secrets from toString() outputs of Credentials implementations (details)
  117. change directory where ditto log files will be created; (details)
  118. change fileNamePattern for TimeBasedRollingPolicy to absolute path; (details)
  119. add log file directory to docker image and grabt ditto user write access; (details)
  120. add env var DITTO_LOGGING_FILE_APPENDER to docker-compose.yml and create volume to access ditto logs on host machine; (details)
  121. don't try to publish ExpiryAnnouncements for new or deleted policies (optimization) (details)
  122. fixed imports of ditto-connecticity-model OSGi bundle (details)
  123. [#1078] Add AzSaslRequestSigning. (details)
  124. added (currently failing) test case for enriching MergeEvents with extra fields using the CachingSignalEnrichmentFacade (details)
  125. fixed CachingSignalEnrichmentFacade for ThingMerged events (details)
  126. fix docker image name; (details)
  127. uncomment resources for easier testing; (details)
  128. adjusted example usage of Ditto Java Client (details)
  129. [#1078] Add option to set SR in AzSaslRequestSigning. (details)
  130. Enable separate configuration for minimum reconnect delay for MQTT broker initiated disconnects of MQTT sessions (details)
  131. [#1078] rename "sr" to "endpoint" in AzSaslRequestSigning. (details)
  132. fixed test.conf (details)
  133. fixed connection-test.conf (details)
  134. [#1078] Make "endpoint" of AzSaslRequestSigning mandatory. (details)
  135. [#1078] Allow AzSaslRequestSigning to authenticate AMQP 1.0 connections. (details)
  136. [#1078] Make JSON field definitions of request signing factories final. (details)
  137. [#1078] Fix ConnectionValidatorTest. (details)
  138. add pod to initialize ditto logs directory on host vm; (details)
  139. use gid 1000 for ditto group; (details)
  140. [#1078] Fix AMQP username of AzSaslRequestSigning. (details)
  141. [#1078] use DittoDuration format for AzSaslRequestSigning's ttl parameter. (details)
  142. rename volume for ditto log files; (details)
  143. add prerequisite to documentation for ditto log files; (details)
  144. #586 ignore duplicate headers (log warning only), clean up connectivity.conf (details)
  145. [#1078] set default TTL of az-sasl to 1 week to prevent cascading backoff. (details)
  146. Filter expired messages based on creation-time and ttl headers (details)
  147. #586 add entity placeholders to resolver creators to use in kafka targets (details)
  148. [#1078] provide actorSystem in ClientActorPropsFactory#getActorPropsForType instead of having it in every DittoService (details)
  149. #586 add dispatcher for alpakka kafka (details)
  150. #586 use dispatcher only for consuming messages from kafka (details)
  151. [#1078] add test for SaslPlainCredentialsSupplier (details)
  152. [#1078] split request signing factories into different factories for http push and amqp (details)
  153. create $DITTO_HOME and $DITTO_LOGS directory inside the one RUN directive for all dockerfiles; (details)
  154. Add documentation for kafka sources (details)
  155. [#1078] fix DefaultAmqp10ConfigTest (details)
  156. [#1078] Remove test to not verify SSL certificates. (details)
  157. [#1078] Restore support of client-certificate credentials with basic-auth for SaslPlainCredentialsSupplier. (details)
  158. #586 suffix kafka consumer/producer client ids (details)
  159. [#1078] move documentation on HMAC signing onto extra page and reference it from HTTP and AMQP 1.0 bindings. (details)
  160. [#1078] add blog post for HMAC signing for HTTP push and AMQP connections (details)
  161. fix rounding up "policyExpiryGranularity" to "0" (disabling it) (details)
  162. update installation-operating.md; (details)
  163. [#1078] update little parts on the documentation of HMAC algorithms (details)
  164. [#1078] fix how AMQP connections handle the validateCertificates configuration, which was causing timeouts when connecting to a secured resource with validateCertificates=false. Also re-add the 'testTLSConnectionWithoutCertificateCheck' which verifies the correct behavior for this. (details)
  165. [#1078] add HMAC signing to sidebar and include examples section (details)
  166. [#1060] Connectivity: Add reserved header http.path to set the path of outgoing HTTP requests. (details)
  167. #586 drop consumed messages in dry run mode, disable auto commit in dry run mode (details)
  168. [#1078] Fix typos. (details)
  169. stabilize coordinated shutdown hook in BaseClientActor for sending connection announcements: (details)
  170. update Akka to 2.6.15 and Akka Management to 1.1.0 (details)
  171. #586 use streams to publish messages to kafka (details)
  172. #586 fix test (details)
  173. fix HttpPushFactoryTest by using a parallelism with power of 2 (details)
  174. adjusted gateway.conf to let "service-requests-done" coordinated shutdown phase timeout be 12s, 2s longer than the "ditto.gateway.http.coordinated-shutdown-timeout" (details)
  175. try to fix EnformcentFlowTest (details)
  176. [#1060] Adjust AwsRequestSigning to support S3 better. (details)
  177. [#1078] Add cloud integration examples using HMAC. (details)
  178. fixed EnforcementFlow parallelism (details)
  179. Fix naming (details)
  180. downgrade to Akka 2.6.14 again after Akka streams has some changes (or even a bug) to attribute propagation which could lead to a very different behavior (details)
  181. enable POST, PUT and DELETE requests for akka management api; (details)
  182. [#1088] retry starting BaseClientActors when they fail when being started by the ConnectionPersistenceActor. Escalate failures of the router pool to the supervisor actor which can restart the ConnectionPersistenceActor. (details)
  183. updated to Akka 2.6.15 again and fixed EnforcementFlowTest (details)
  184. #586 use SendProducer instead of Producer.flexiFlow() to be able to handle the publish errors/acknowledgfements correctly, re-enabled KafkaPublisherActorTest (details)
  185. don't remove all other addresses in ClusterMemberRemovedAware when own instance was terminated (details)
  186. #586 move producer config to producer section (details)
  187. remove non needed Attributes inputBuffer on EnforcementFlow (details)
  188. review: made OneForOneEscalateStrategy final + minor javadoc addition (details)
  189. #586 send connection failure message to parent if kafka producer stream fails (details)
  190. #586 disable parallel publishing, use separate dispatcher for publishing (details)
  191. [#1078] rewrite Azure IoT Hub example payload mapping to map the ditto protocol message to a direct method (details)
  192. [#1078] fix use of jekylls %raw% in markdown (details)
  193. adjusted "role" for all splitBrain resolver configs to be unset (details)
  194. [#1078] add az-sasl to connection json in the documentation (details)
  195. Adjust documentation for kafka sources (details)
  196. #586 add dedicated kafka dispatcher also for unit tests (details)
  197. configure "least-shard-allocation-strategy" algorithm in order to get better shard allocation / rebalancing (details)
  198. downgrade Akka version to 2.6.13 (details)
  199. [#1078] align az-sasl hmac signing examples with the previous examples (details)
  200. [#1060] test all paths of reserved headers in HttpPublisherActor (details)
  201. #586 restart source if stream fails (details)
  202. downgrade Akka Management version to 1.0.10 (details)
  203. #586 drop consumed messages in dry run mode, disable auto commit in dry run mode (details)
  204. #586 make kafka producer restart backoff configurable (details)
  205. #586 fix KafkaPublisherActorTest (details)
  206. gracefully shutdown logback-classic logging in DittoService during coordinated shutdown (details)
  207. add debug log to postStop method; (details)
  208. Adds entity placeholder for http push target path (details)
  209. #586 make kafka producer restart backoff configurable, move config for alpakka into separate config inside of consumer and producer, implemented config model for consumer and producer (details)
  210. #586 wrap kafka send result in source and use flatmap to fail the source and restart it (details)
  211. #586 recreate send producer and source queue when the producer stream is restarted (details)
  212. #586 fix config file for tests (details)
  213. #586 fix wrong parentheses in connectivity config (details)
  214. to rule out runtime classnotfound errors, put janio back to "compile" scope (details)
  215. #586 fix more wrong parentheses in connectivity config (details)
  216. log shutdown reason; (details)
  217. return completionStage from AkkaManagement.stop(); (details)
  218. [#1078] Documentation: Replace "message name" by "message subject" for consistency. (details)
  219. [#1078] date hmac blogpost. (details)
  220. #586 use RestartFlow instead of RestartSource to keep the source queue and restart only the publishing flow, fix handling queue offer result (also for amqp publisher) (details)
  221. [#1078] Give testTLSConnectionWithoutCertificateCheck more time; remove actor system contamination between tests. (details)
  222. stabilize coordinated shutdown hook in BaseClientActor for sending connection announcements: (details)
  223. set allowed clock skew to 10 seconds to tolerate discrepancy when verifying local time against exp and nbf claims in JWT; (details)
  224. Add setter for multiple subjects at once (details)
  225. #586 add test to verify usage of entity:id placeholder in http push target (details)
  226. #586 remove some debug statements (details)
  227. added slidedeck for Ditto 2.0 release notes + roadmap (details)
  228. add new config key 'allowed-clock-skew' to oauth config; (details)
  229. add unit test for setSubjects, add @since tag (details)
  230. fix todo, remove unused import (details)
  231. fix license header (details)
  232. configure mongodb circuit breaker timeout higher (details)
Commit 060c0ef9886458df9adec07ed1304761a3d06918 by Florian Fendt
Add connectivity announcements for when a connection was opened or closed

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was addedsignals/announcements/connectivity/src/main/java/org/eclipse/ditto/signals/announcements/connectivity/package-info.java
The file was addedsignals/announcements/connectivity/src/main/java/org/eclipse/ditto/signals/announcements/connectivity/AbstractConnectivityAnnouncement.java
The file was addedsignals/announcements/connectivity/src/test/java/org/eclipse/ditto/signals/announcements/connectivity/ConnectionOpenedAnnouncementTest.java
The file was addedsignals/announcements/connectivity/src/main/java/org/eclipse/ditto/signals/announcements/connectivity/ConnectionClosedAnnouncement.java
The file was modified model/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectionId.java (diff)
The file was addedsignals/announcements/connectivity/src/main/java/org/eclipse/ditto/signals/announcements/connectivity/ConnectivityAnnouncement.java
The file was addedsignals/announcements/connectivity/src/main/java/org/eclipse/ditto/signals/announcements/connectivity/ConnectionOpenedAnnouncement.java
The file was addedsignals/announcements/connectivity/pom.xml
The file was modified signals/announcements/pom.xml (diff)
The file was addedsignals/announcements/connectivity/src/test/java/org/eclipse/ditto/signals/announcements/connectivity/ConnectionClosedAnnouncementTest.java
The file was modified bom/pom.xml (diff)
Commit 296e2dc939befe2871e21b8a7c2c05e5dfee266a by Florian Fendt
Add connectivity announcements to the ditto protocol

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was addedprotocol/src/main/java/org/eclipse/ditto/protocol/adapter/connectivity/AbstractConnectivityAdapter.java
The file was addedprotocol/src/test/java/org/eclipse/ditto/protocol/mappingstrategies/ConnectivityAnnouncementMappingStrategiesTest.java
The file was modified protocol/pom.xml (diff)
The file was removedprotocol/src/main/java/org/eclipse/ditto/protocol/adapter/things/EmptyPathMatcher.java
The file was addedprotocol/src/test/java/org/eclipse/ditto/protocol/adapter/connectivity/ConnectivityAnnouncementAdapterTest.java
The file was modified protocol/src/test/java/org/eclipse/ditto/protocol/ImmutableTopicPathBuilderTest.java (diff)
The file was modified protocol/src/main/java/org/eclipse/ditto/protocol/ProtocolFactory.java (diff)
The file was modified policies/model/src/main/java/org/eclipse/ditto/policies/model/signals/announcements/AbstractPolicyAnnouncement.java (diff)
The file was modified protocol/src/main/java/org/eclipse/ditto/protocol/mapper/SignalMapperFactory.java (diff)
The file was modified protocol/src/test/java/org/eclipse/ditto/protocol/TestConstants.java (diff)
The file was addedprotocol/src/test/java/org/eclipse/ditto/protocol/adapter/connectivity/ParametrizedConnectivityAnnouncementAdapterTest.java
The file was modified connectivity/model/src/main/java/org/eclipse/ditto/connectivity/model/signals/announcements/ConnectivityAnnouncement.java (diff)
The file was addedprotocol/src/main/java/org/eclipse/ditto/protocol/adapter/connectivity/ConnectivityAdapter.java
The file was addedprotocol/src/main/java/org/eclipse/ditto/protocol/adapter/EmptyPathMatcher.java
The file was modified protocol/src/main/java/org/eclipse/ditto/protocol/ImmutableTopicPathBuilder.java (diff)
The file was modified protocol/src/main/java/org/eclipse/ditto/protocol/mappingstrategies/MappingStrategiesFactory.java (diff)
The file was addedprotocol/src/main/java/org/eclipse/ditto/protocol/mappingstrategies/ConnectivityAnnouncementMappingStrategies.java
The file was modified protocol/src/test/java/org/eclipse/ditto/protocol/ProtocolFactoryTest.java (diff)
The file was modified protocol/src/main/java/org/eclipse/ditto/protocol/adapter/things/MessageCommandResponseAdapter.java (diff)
The file was modified protocol/src/main/java/org/eclipse/ditto/protocol/TopicPathBuilder.java (diff)
The file was modified protocol/src/test/java/org/eclipse/ditto/protocol/ProtocolFactoryParameterizedTest.java (diff)
The file was modified protocol/src/main/java/org/eclipse/ditto/protocol/adapter/DittoProtocolAdapter.java (diff)
The file was addedprotocol/src/test/java/org/eclipse/ditto/protocol/adapter/connectivity/DefaultConnectivityCommandAdapterProviderTest.java
The file was modified protocol/src/main/java/org/eclipse/ditto/protocol/adapter/things/MessageCommandAdapter.java (diff)
The file was modified protocol/src/main/java/org/eclipse/ditto/protocol/ImmutableTopicPath.java (diff)
The file was modified connectivity/model/src/main/java/org/eclipse/ditto/connectivity/model/signals/announcements/AbstractConnectivityAnnouncement.java (diff)
The file was addedprotocol/src/main/java/org/eclipse/ditto/protocol/adapter/connectivity/ConnectivityAnnouncementAdapter.java
The file was addedprotocol/src/main/java/org/eclipse/ditto/protocol/mappingstrategies/AbstractConnectivityMappingStrategies.java
The file was modified protocol/src/main/java/org/eclipse/ditto/protocol/TopicPath.java (diff)
The file was addedprotocol/src/main/java/org/eclipse/ditto/protocol/adapter/connectivity/ConnectivityCommandAdapterProvider.java
The file was addedprotocol/src/main/java/org/eclipse/ditto/protocol/mapper/ConnectivityAnnouncementSignalMapper.java
The file was addedprotocol/src/main/java/org/eclipse/ditto/protocol/adapter/connectivity/DefaultConnectivityCommandAdapterProvider.java
The file was modified protocol/src/test/java/org/eclipse/ditto/protocol/adapter/DittoProtocolAdapterParameterizedTest.java (diff)
Commit 4e03f1cb895ff9ae98e7b0aae6810be790a46aef by Florian Fendt
Also resolve connectivity signals from Adaptables

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified protocol/src/main/java/org/eclipse/ditto/protocol/adapter/DittoProtocolAdapter.java (diff)
The file was modified protocol/src/main/java/org/eclipse/ditto/protocol/adapter/DefaultAdapterResolver.java (diff)
The file was modified protocol/src/test/java/org/eclipse/ditto/protocol/adapter/DittoProtocolAdapterTest.java (diff)
Commit 091fd76c0cc81ebb308caf6d4b15b00c08edf3e9 by Florian Fendt
Add connection announcements to the Topic

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified connectivity/model/src/main/java/org/eclipse/ditto/connectivity/model/ImmutableFilteredTopic.java (diff)
The file was modified connectivity/model/src/test/java/org/eclipse/ditto/connectivity/model/ImmutableFilteredTopicTest.java (diff)
The file was modified connectivity/model/src/main/java/org/eclipse/ditto/connectivity/model/Topic.java (diff)
Commit d66a42128d9367aba7bed300620bdbc8b215c281 by Florian Fendt
Add connection announcements to the signal filter

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/persistence/SignalFilterTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/persistence/SignalFilter.java (diff)
Commit 5b43125994f6efd38e76532174e34c3216e65fa5 by Florian Fendt
Don't subscribe to internal Ditto PubSub for connectivity announcements as they are only sent outwards

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified thingsearch/service/src/main/resources/things-search.conf (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java (diff)
Commit 76271dd2add4cccf6edd110ca8547799527c95b4 by Thomas Jaeckle
added Ditto 2.0 to documentation version picker

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified documentation/src/main/resources/_config.yml (diff)
Commit e0819d8bd5e5d181b84994b4eb500ac0c5588580 by Thomas Jaeckle
activate binary compatibility check to version 2.0.0

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified pom.xml (diff)
Commit 736a9d2170bef64d97676cbb8a7c0b14910d5e8a by noreply
added Ditto 2.0.x to SECURITY.md
The file was modified SECURITY.md (diff)
Commit c0d472deca86828f5bd730ef1137f5488d156538 by Stefan Maute
restructure kubernetes deployment Readmes;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified deployment/helm/README.md (diff)
The file was addeddeployment/kubernetes/README.md
The file was modified deployment/kubernetes/minikube/README.md (diff)
The file was modified deployment/kubernetes/k3s/README.md (diff)
Commit f4863220e944cf7ddaca61a01094dedbdf5940ad by Stefan Maute
bump nginx version to 1.20-alpine;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified deployment/kubernetes/deploymentFiles/ditto/pod-reader-role.yaml (diff)
The file was modified deployment/kubernetes/deploymentFiles/mongodb-statefulset/mongodb-statefulset.yaml (diff)
The file was modified deployment/kubernetes/deploymentFiles/mongodb/mongodb.yaml (diff)
The file was modified deployment/kubernetes/deploymentFiles/mongodb-statefulset/persistent-volume.yaml (diff)
The file was modified deployment/kubernetes/deploymentFiles/swagger/swagger.yaml (diff)
The file was modified deployment/kubernetes/deploymentFiles/mongodb-statefulset/storage-class.yaml (diff)
The file was modified deployment/kubernetes/deploymentFiles/nginx/nginx.yaml (diff)
The file was modified deployment/kubernetes/minikube/README.md (diff)
Commit e67b80dcb0f53dd18bd5466eca8b2429917fdb48 by Vadim Günther
#1052: Fix typo

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was modified protocol/src/main/java/org/eclipse/ditto/protocol/mapper/ConnectivityAnnouncementSignalMapper.java (diff)
Commit f3cbc12ce26beb2833d75c9710bc9dcf0809bd4f by Florian Fendt
Send connection announcement after opening and before closing a connection

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified connectivity/service/src/test/resources/test.conf (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ClientConfig.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/AbstractBaseClientActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultClientConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/config/DefaultClientConfigTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActorTest.java (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified connectivity/service/src/test/resources/client-test.conf (diff)
Commit d80c088563a76f292e04aeee98ec65d683ac1380 by Florian Fendt
Close connections when shutting down the the cluster (which will trigger sending a close announcement)

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java (diff)
Commit 7d84a3e4380567f21665204cd21b077e12638ffa by Florian Fendt
Close connection before deleting it (which will automatically send a connection announcement)

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/FaultyClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/persistence/strategies/commands/DeleteConnectionStrategy.java (diff)
The file was modified connectivity/service/src/test/resources/logback-test.xml (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/ErrorHandlingActorTest.java (diff)
Commit 88e638efc853d1a47f18a42f3aff604486a3cf83 by Florian Fendt
fix ErrorHandlingActorTest

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/FaultyClientActor.java (diff)
Commit d1cb36daf79fb4790326929504c537db9af1f469 by Yannic Klem
Avoids throwing exceptions in ditto metrics and return more or less
reasonable return values in combination with a WARN log instead

* The reason for this is that we don't want productive code to break
  because of errors in metrics

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modified internal/utils/metrics/src/main/java/org/eclipse/ditto/internal/utils/metrics/instruments/timer/PreparedKamonTimer.java (diff)
The file was modified internal/utils/metrics/src/test/java/org/eclipse/ditto/internal/utils/metrics/instruments/timer/StartedKamonTimerTest.java (diff)
The file was modified internal/utils/metrics/src/main/java/org/eclipse/ditto/internal/utils/metrics/instruments/gauge/KamonGauge.java (diff)
The file was modified internal/utils/metrics/src/main/java/org/eclipse/ditto/internal/utils/metrics/instruments/timer/StartedKamonTimer.java (diff)
The file was modified internal/utils/metrics/src/main/java/org/eclipse/ditto/internal/utils/metrics/instruments/counter/KamonCounter.java (diff)
The file was modified internal/utils/metrics/src/main/java/org/eclipse/ditto/internal/utils/metrics/instruments/histogram/KamonHistogram.java (diff)
Commit 454c7b179ffa510f02262c262b9e7b6492fe730e by noreply
fixed typo in 2.0 announcement
The file was modified documentation/src/main/resources/_posts/2021-05-06-release-announcement-200.md (diff)
Commit 03e22b12e88d8d4ef2def331466dd4abc4d9a60d by Yannic Klem
only log warning if already stopped timer should be stopped

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modified internal/utils/metrics/src/main/java/org/eclipse/ditto/internal/utils/metrics/instruments/timer/StartedKamonTimer.java (diff)
Commit 28bcfee485ac72ef7ac77d89b5c8a86c0a87da53 by Thomas Jaeckle
fixed parallelism of search-updater using "flatMapMerge"
* added async() boundary which was missing and caused parallelism to not have an effect
* additionally made it possible to configure a minPoolSize for MongoDB connections

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/config/MongoDbConfig.java (diff)
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/MongoClientWrapper.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/MongoSearchUpdaterFlow.java (diff)
The file was modified internal/utils/config/src/main/resources/ditto-mongo.conf (diff)
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/config/DefaultConnectionPoolConfig.java (diff)
The file was modified thingsearch/service/src/main/resources/things-search.conf (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/EnforcementFlow.java (diff)
The file was modified documentation/src/main/resources/pages/ditto/installation-operating.md (diff)
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/MongoHealthChecker.java (diff)
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/DittoMongoClientBuilder.java (diff)
Commit 2d658ba11f887acfde3e724f7be3df54ce34ed2b by Thomas Jaeckle
added custom dispatchers for flatMapMerge() with async() usage in
* connectivity
* things-search

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/DefaultHttpPushFactory.java (diff)
The file was modified connectivity/service/src/test/resources/test.conf (diff)
The file was modified thingsearch/service/src/test/resources/actors-test.conf (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/EnforcementFlow.java (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/MongoSearchUpdaterFlow.java (diff)
The file was modified thingsearch/service/src/main/resources/things-search.conf (diff)
Commit 34f4a5cc970d81d8b603a37fe241e166b83c6a1c by Thomas Jaeckle
fixed EnforcementFlowTest

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified thingsearch/service/src/test/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/EnforcementFlowTest.java (diff)
Commit 761b24990af68f116248043a8caf3cb614eaa756 by Thomas Jaeckle
added missing dispatcher to search test config

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified thingsearch/service/src/test/resources/test.conf (diff)
Commit 2e289c37464cd54f0a5ce8dca4907d810facbc7e by Thomas Jaeckle
fixed SearchActorIT

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified thingsearch/service/src/test/java/org/eclipse/ditto/thingsearch/service/starter/actors/SearchActorIT.java (diff)
Commit 9e253d17cb83a04fe9a65848d736a044f5e3931b by Thomas Jaeckle
fixed that Policy Error responses in WS contained wrong topic path
namespace and name were not correctly separated

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/endpoints/routes/websocket/WebSocketRoute.java (diff)
The file was modified protocol/src/main/java/org/eclipse/ditto/protocol/ImmutableTopicPath.java (diff)
The file was modified protocol/src/test/java/org/eclipse/ditto/protocol/adapter/policies/PolicyErrorResponseAdapterTest.java (diff)
The file was modified things/model/src/main/java/org/eclipse/ditto/things/model/signals/commands/ThingErrorResponse.java (diff)
The file was modified policies/model/src/main/java/org/eclipse/ditto/policies/model/signals/commands/PolicyErrorResponse.java (diff)
The file was modified protocol/src/main/java/org/eclipse/ditto/protocol/mappingstrategies/ThingModifyCommandMappingStrategies.java (diff)
Commit 0a56093fd3711fcb82f0bef3a5fbbbaa288eeed3 by Florian Fendt
#1052: validate that connection announcements can only be used with client count 1

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified connectivity/model/src/main/java/org/eclipse/ditto/connectivity/model/ImmutableConnection.java (diff)
The file was modified connectivity/model/src/test/java/org/eclipse/ditto/connectivity/model/ImmutableConnectionTest.java (diff)
Commit 5008be49fa6f45f354ad4dc403c1cf41d93c0190 by Thomas Jaeckle
fixed default config of retrieval.parallelism to be a factor of 2

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified thingsearch/service/src/test/resources/actors-test.conf (diff)
The file was modified thingsearch/service/src/main/resources/things-search.conf (diff)
Commit c5ab4bcd44d3a7c36f68c2fc5858192c6363b462 by Thomas Jaeckle
removed .withAttributes(Attributes.inputBuffer from search-updater-flows

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/EnforcementFlow.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/MongoSearchUpdaterFlow.java (diff)
Commit 03fd6f226ff571d525c3784223c2e30ed9963c13 by Stefan Maute
uncomment resources config for all services;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified deployment/kubernetes/deploymentFiles/ditto/ditto-cluster.yaml (diff)
Commit 27a4d3c9cfd357ff6c8cbdc55f37ff7d08830d1f by Vadim Günther
#1052: Add documentation for connection announcement

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was addeddocumentation/src/main/resources/pages/ditto/protocol/examples/connections/generated/announcements/openedConnection.md
The file was addeddocumentation/src/main/resources/pages/ditto/protocol/examples/connections/protocol-examples-connections-announcement-opened.md
The file was addeddocumentation/src/main/resources/pages/ditto/protocol/examples/connections/generated/announcements/closedConnection.md
The file was addeddocumentation/src/main/resources/pages/ditto/protocol-specification-connections-announcement.md
The file was modified documentation/src/main/resources/_data/sidebars/ditto_sidebar.yml (diff)
The file was modified documentation/src/main/resources/pages/ditto/basic-connections.md (diff)
The file was addeddocumentation/src/main/resources/pages/ditto/protocol-specification-connections.md
The file was addeddocumentation/src/main/resources/pages/ditto/protocol/examples/connections/protocol-examples-connections-announcement-closed.md
The file was modified documentation/src/main/resources/pages/ditto/connectivity-manage-connections.md (diff)
The file was modified connectivity/service/src/test/resources/logback-test.xml (diff)
Commit 60b19ebfef7fe7302baca7da58b729cd2a1c4dde by Vadim Günther
#1052: mention connection announcements in protocol-specification.md

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/protocol-specification.md (diff)
Commit 3431960ef0761079147a5a54f0cdd92e99d3e3b5 by Dominik Guggemos
relax mqtt validation for source header mappings

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/Mqtt3Validator.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/Mqtt3ValidatorTest.java (diff)
Commit 7d7581714a4a10d1ae48041b2026af82a06ac563 by Yannic Klem
Fixed missing publish metrics for published messages without
issued/requested acknowledgements

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/SendingTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/Sending.java (diff)
Commit 6b486dc10153c85aaa30be1637b29afd71747565 by Vadim Günther
1052: fix wording for connection announcement

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/protocol-specification-connections-announcement.md (diff)
The file was modified documentation/src/main/resources/pages/ditto/protocol-specification-connections.md (diff)
Commit 2e3a4fb0dc3f0b601765f01461ac3fc6a6449c92 by Thomas Jaeckle
fixed that for commands requesting "search-persisted" the wrong write concern was used
* collections were mixed up
* also fixed some logging in connectivity which missed the correlation-id

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/SearchUpdaterStream.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseConsumerActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BasePublisherActor.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/MongoSearchUpdaterFlow.java (diff)
Commit 9d6d8e7ce80402004c03889aefbdf34f0dcfc02a by noreply
added "docker pulls" badge to readme
The file was modified README.md (diff)
Commit 27534ba0dbd60cd79e199f4dc2d080186d362241 by Yufei Cai
Issue #1060: add test cases for Azure and AWS signing processes

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSignatureTest.java
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzMonitorSignatureTest.java
Commit 391e3a29450e6b1fccabec66695886e77e17324f by Thomas Jaeckle
made AckUpdater work with ddata sharding
having a shard count > 1
* added a unit test testing with 2 systems and remote declared acks

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified internal/utils/pubsub/src/test/java/org/eclipse/ditto/internal/utils/pubsub/actors/AckUpdaterTest.java (diff)
The file was modified internal/utils/pubsub/src/main/java/org/eclipse/ditto/internal/utils/pubsub/actors/AckUpdater.java (diff)
Commit f110f6d67d09c1c8b197c0bd603b93128589e990 by Yufei Cai
Issue #1060: add azure monitor request signing

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/RequestSigning.java
The file was removedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzMonitorSignatureTest.java
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzMonitorRequestSigning.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPublishTarget.java (diff)
The file was removedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSignatureTest.java
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzMonitorRequestSigningTest.java
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigningTest.java
Commit 69fb9e2574fd062a1f73de09396008d7f8aa6879 by Yufei Cai
Issue #1060: Add AwsRequestSigning; switch signing timestamp formatter to DateTimeFormatter; add TODO in AbstractBaseClientActorTest

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/endpoints/routes/things/ThingsRoute.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/RequestSigning.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzMonitorRequestSigning.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/AbstractBaseClientActorTest.java (diff)
The file was addedbase/service/src/main/java/org/eclipse/ditto/base/service/UriEncoding.java
The file was modified gateway/service/src/test/java/org/eclipse/ditto/gateway/service/endpoints/utils/UriEncodingTest.java (diff)
The file was removedgateway/service/src/main/java/org/eclipse/ditto/gateway/service/endpoints/utils/UriEncoding.java
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigning.java
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/endpoints/routes/things/FeaturesRoute.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigningTest.java (diff)
Commit e9600fabd9b94dc1c9bd7ab89ab7990ec5efaedf by Yufei Cai
Issue #1060: Add HmacCredentials.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/model/src/main/java/org/eclipse/ditto/connectivity/model/CredentialsVisitor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/internal/ssl/PublicKeyAuthenticationFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/internal/ssl/SSLContextCreator.java (diff)
The file was modified connectivity/model/src/main/java/org/eclipse/ditto/connectivity/model/Credentials.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/validation/package-info.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/validation/SshTunnelValidator.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/internal/ssl/KeyManagerFactoryFactory.java (diff)
The file was addedconnectivity/model/src/main/java/org/eclipse/ditto/connectivity/model/HmacCredentials.java
The file was addedconnectivity/model/src/test/java/org/eclipse/ditto/connectivity/model/HmacCredentialsTest.java
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/NoOpRequestSigning.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/tunnel/SshTunnelActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/tunnel/ClientSessionCredentialsVisitor.java (diff)
Commit 53f522c154f0428be30181da1340cab7e99bd2ee by noreply
Fix broken links in installation-operating.md
The file was modified documentation/src/main/resources/pages/ditto/installation-operating.md (diff)
Commit f1eb522712f7afb5b034bd91e60eeb63a39de74a by Yannic Klem
Implement basic structure for kafka consumers

* All TODOs are prefixed with 'TODO: kafka source'

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConnectionFactory.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/ConsumerPropertiesFactory.java
The file was modified connectivity/service/pom.xml (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/ConsumerData.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/DefaultKafkaConnectionFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActor.java (diff)
The file was modified bom/pom.xml (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaValidator.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaValidatorTest.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageToExternalMessage.java
Commit ef64c1b83774722a3ec8fac541fa0a3b22a5bf1b by Thomas Jaeckle
added logging a type hint to AbstractEnforcement successful enforcement
* fixed toString() in Contextual

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/enforcement/Contextual.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/enforcement/AbstractEnforcement.java (diff)
Commit 8b177c93acbdedf78cc784035784961e1c356039 by Thomas Jaeckle
put log statements with debug content to DEBUG level

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified internal/utils/pubsub/src/main/java/org/eclipse/ditto/internal/utils/pubsub/actors/Publisher.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/enforcement/AbstractEnforcement.java (diff)
Commit 2b173bd016f1401b8bda00dc461d119d3d5abebd by Yannic Klem
Added validation for source address and target header mappings

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaValidator.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaValidatorTest.java (diff)
Commit e641a8c5206daf69b326b582d7f3f39c63a792e8 by Yufei Cai
Issue #1060: add dynamic loading of HTTP request signing algorithms.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzMonitorRequestSigningFactory.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigning.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzMonitorRequestSigning.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/RequestSigningFactory.java
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigningFactory.java
The file was modified connectivity/service/src/test/resources/test.conf (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPushFactoryTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultHttpPushConfig.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/config/DefaultConnectionConfigTest.java (diff)
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/config/DefaultHttpPushConfigTest.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/NoOpRequestSigning.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/RequestSigningExtension.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/HttpPushConfig.java (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPublisherActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPublisherActorTest.java (diff)
The file was addedconnectivity/service/src/test/resources/http-push-test.conf
Commit 5107aab3cb6cc25c06fd9069fcc495aa037b2762 by Thomas Jaeckle
review: fixed comment which still pointed to outdated enum name

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/Mqtt3Validator.java (diff)
Commit 970902ddd7831fcc0bd308cebcbe2d6c0695abcc by Yannic Klem
Handle exceptions in MessageProcessor to avoid exceptions in KafkaStreams

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/IncomingMessageHandler.java
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageToExternalMessage.java
Commit ffa92353c3987770142ac1e08d42a6f01dbde99b by Yannic Klem
Make move the logic again to a transformer

* I noticed that the processor I used seems to be deprecated and even worse
  the pattern I used to split the stream for exceptions and messages
  was bad practice.
* Adds unit tests for the transformer

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java (diff)
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformerTest.java
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/IncomingMessageHandler.java
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformer.java
Commit 8741e0ddd8ac8c0c13003738136e109469dd6284 by Stefan Maute
use var keyword;
fix typos;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified internal/utils/pubsub/src/test/java/org/eclipse/ditto/internal/utils/pubsub/actors/AckUpdaterTest.java (diff)
The file was modified internal/utils/pubsub/src/main/java/org/eclipse/ditto/internal/utils/pubsub/actors/AckUpdater.java (diff)
Commit 55314d65d093351d41927469d35683cc85839b37 by Yannic Klem
Use correct branch names to access them in the map

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java (diff)
Commit 82ddf5204459ab696a7df4092f50d182ca3481bb by Stefan Maute
use min interval from backoffConfig to create RestartSettings;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/SearchUpdaterStream.java (diff)
Commit 2fc2f4cfaebd349608f009a3705b43f5be6141c6 by Yufei Cai
Issue #1060: Only validate certificate for client certificate credentials in the absence of server certificate; do not throw UnsupportedOperationsException in other cases.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/validation/ConnectionValidator.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/internal/ssl/SSLContextCreator.java (diff)
Commit 5a7ac983b1c47771374fd140bc25fbec5e853b6e by Johannes Schneider
move start of stream to preStart hook

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java (diff)
Commit 0e36e3559839f3b9009be5d69060e5c9b7dfbe83 by Johannes Schneider
move initialisation of logger back to top

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java (diff)
Commit 7e1dc071b42fe0a0b6739b25e43c63db1296c6d4 by Yannic Klem
Use scalas Either to avoid using generic Object as return type

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformer.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformerTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java (diff)
Commit 584b26bb1a6ab646b6490cd10f170f5330e3104d by Yannic Klem
WIP: switch to akka-stream-kafka

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformer.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java (diff)
The file was modified connectivity/service/pom.xml (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformerTest.java (diff)
The file was modified bom/pom.xml (diff)
Commit f28a8eb890cdd20dc0417b4d7003df039001587c by Thomas Jaeckle
fix MQTT protocol level acknowledgements
* when "reconnectForRedelivery=false", sucessful MQTT ACKs are issued even when a redelivery of the message is expected -> changed that behavior to only ACK when no redelivery is expected
* made "cleanSession" config not to be based on "reconnectForRedelivery" value - apply a default of "false", but make the default configurable in connectivity.conf
* added a new "event-loop-threads" option configuring the used HiveMQTT client to use a fixed amount of netty event-loop threads instead of having them dynamically calculcated by default based on the processor count
* adjusted MQTT docs

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/AbstractHiveMqttClientFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/AbstractMqttClientActor.java (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/DefaultHiveMqtt3ClientFactory.java (diff)
The file was modified documentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-mqtt5.md (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/MockHiveMqtt3ClientFactory.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/MockHiveMqtt5ClientFactory.java (diff)
The file was modified documentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-mqtt.md (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/HiveMqttClientFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/MqttConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/MqttSpecificConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/AbstractMqttConsumerActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/DefaultHiveMqtt5ClientFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultMqttConfig.java (diff)
Commit bed5bb2678c6485e67be75ac8ba2dcb9cd6c2711 by Thomas Jaeckle
fixed applying "eventLoopThreads" option
* always use timer in order to schedule redelivery of unacked messages when using "reconnectForRedelivery"
* undid not sending back "acknowledgement" when not using "reconnectForRedelivery" as MQTT brokers would not re-deliver the message anyway
* added documentation for configuring "acknowledgementRequests" for MQTT sources in order to handle QoS 0/1/2 correctly

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/AbstractHiveMqttClientFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/AbstractMqttClientActor.java (diff)
The file was modified documentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-mqtt5.md (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/MqttConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/AbstractMqttConsumerActor.java (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified documentation/src/main/resources/pages/ditto/basic-connections.md (diff)
The file was modified documentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-mqtt.md (diff)
Commit 6756da878bc18762ad56b45a138de28018400eb3 by Vadim Günther
#1052: edit documentation for topic path of connection announcements

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/protocol-specification-connections-announcement.md (diff)
Commit 3ecf15144e3a74dc5f82f5b6792faaf808a16d18 by Thomas Jaeckle
applied manual reconnect for MQTT connections
* triggering a reconnect based on the situation, e.g. for reconenct because of redelivery, directly reconnect without any delay
* don't setup new hivemq clients for the manual reconnect, but rather reconnect the existing ones
* applied some simplifications caused by this new approach

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/backoff/RetryTimeoutStrategy.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/monitoring/logs/DefaultEvictingQueue.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultMqttConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/MqttConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/monitoring/logs/DefaultMuteableConnectionLogger.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/AbstractHiveMqttClientFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/DefaultHiveMqtt3ClientFactory.java (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/HiveMqtt3ConsumerActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/MockHiveMqtt5ClientFactory.java (diff)
The file was modified documentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-mqtt.md (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/MockHiveMqtt3ClientFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/HiveMqttClientFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/backoff/DuplicationRetryTimeoutStrategy.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/monitoring/logs/EvictingConnectionLogger.java (diff)
The file was modified documentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-mqtt5.md (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/DefaultHiveMqtt5ClientFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/AbstractMqttClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/HiveMqtt5ConsumerActor.java (diff)
Commit 540bb4c0f658c46952228f43937dee29833164a3 by Stefan Maute
make it possible to write logs to Logstash endpoint;
add possibility to disable sysout logs;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified gateway/service/src/main/resources/logback.xml (diff)
The file was modified thingsearch/service/src/main/resources/logback.xml (diff)
The file was modified connectivity/service/src/main/resources/logback.xml (diff)
The file was modified policies/service/src/main/resources/logback.xml (diff)
The file was modified things/service/src/main/resources/logback.xml (diff)
The file was modified concierge/service/src/main/resources/logback.xml (diff)
Commit 0b840e5b49afd04eb68206b9e3d4220ea5b7523d by Stefan Maute
add logstash-logback-encoder and janino dependency;
add RollingFileAppender to logback.xml;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified connectivity/service/src/main/resources/logback.xml (diff)
The file was modified connectivity/service/pom.xml (diff)
The file was modified things/service/src/main/resources/logback.xml (diff)
The file was modified thingsearch/service/src/main/resources/logback.xml (diff)
The file was modified gateway/service/pom.xml (diff)
The file was modified concierge/service/src/main/resources/logback.xml (diff)
The file was modified bom/pom.xml (diff)
The file was modified policies/service/pom.xml (diff)
The file was modified things/service/pom.xml (diff)
The file was modified gateway/service/src/main/resources/logback.xml (diff)
The file was modified concierge/service/pom.xml (diff)
The file was modified policies/service/src/main/resources/logback.xml (diff)
The file was modified thingsearch/service/pom.xml (diff)
Commit ddaa27b6f708e9957f379fd9f55a859bab6c7fe4 by Stefan Maute
add exclude for shade plugin;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified concierge/service/pom.xml (diff)
The file was modified gateway/service/pom.xml (diff)
The file was modified connectivity/service/pom.xml (diff)
The file was modified policies/service/pom.xml (diff)
The file was modified things/service/pom.xml (diff)
The file was modified thingsearch/service/pom.xml (diff)
Commit 6d4e8b63fb5c5fd00612b473838c4511e50f9916 by Stefan Maute
add volume and volumeMounts to access ditto log files;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified deployment/kubernetes/deploymentFiles/ditto/ditto-cluster.yaml (diff)
Commit edafcd58f279942786f4dfde1f1b5938b42f89eb by Vadim Günther
#1052 correct year in licence header

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was modified protocol/src/test/java/org/eclipse/ditto/protocol/adapter/connectivity/ParametrizedConnectivityAnnouncementAdapterTest.java (diff)
Commit 161177140aa75e612881de3f4c92b9f5c9a1092a by Stefan Maute
removed duplicate check for empty failed responses;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/AbstractHiveMqttClientFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/AbstractMqttConsumerActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/AbstractMqttClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseConsumerActor.java (diff)
Commit 866374a57dc88d3405aa5face29440d313cc5baa by Stefan Maute
add missing volumeMounts;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified deployment/kubernetes/deploymentFiles/ditto/ditto-cluster.yaml (diff)
Commit abef6878c995763cdb262f240140f8c0ebcc600c by Stefan Maute
add logging possibilities to installation-operating.md;
make maxHistory and totalSizeCap configurable via env vars;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified thingsearch/service/src/main/resources/logback.xml (diff)
The file was modified concierge/service/src/main/resources/logback.xml (diff)
The file was modified policies/service/src/main/resources/logback.xml (diff)
The file was modified things/service/src/main/resources/logback.xml (diff)
The file was modified connectivity/service/src/main/resources/logback.xml (diff)
The file was modified deployment/kubernetes/deploymentFiles/ditto/ditto-cluster.yaml (diff)
The file was modified gateway/service/src/main/resources/logback.xml (diff)
The file was modified documentation/src/main/resources/pages/ditto/installation-operating.md (diff)
Commit 4bddd989aa188d0c91c02873540564793ee085b9 by Thomas Jaeckle
review: prefixed all logging related environment variables with `DITTO_LOGGING_`

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified thingsearch/service/src/main/resources/logback.xml (diff)
The file was modified deployment/kubernetes/deploymentFiles/ditto/ditto-cluster.yaml (diff)
The file was modified things/service/src/main/resources/logback.xml (diff)
The file was modified connectivity/service/src/main/resources/logback.xml (diff)
The file was modified concierge/service/src/main/resources/logback.xml (diff)
The file was modified policies/service/src/main/resources/logback.xml (diff)
The file was modified documentation/src/main/resources/pages/ditto/installation-operating.md (diff)
The file was modified gateway/service/src/main/resources/logback.xml (diff)
Commit 72120741fddd8352b6b6d82b7e1a8a68392c6538 by Thomas Jaeckle
fixed logback XML error

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified gateway/service/src/main/resources/logback.xml (diff)
The file was modified thingsearch/service/src/main/resources/logback.xml (diff)
The file was modified things/service/src/main/resources/logback.xml (diff)
The file was modified policies/service/src/main/resources/logback.xml (diff)
Commit f1b3a3bf390ed19c58009d03c692b61922f0cd40 by Thomas Jaeckle
added Ditto 2.0.1 release notes

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified documentation/src/main/resources/_data/sidebars/ditto_sidebar.yml (diff)
The file was modified documentation/src/main/resources/pages/ditto/release_notes_200.md (diff)
The file was addeddocumentation/src/main/resources/pages/ditto/release_notes_201.md
Commit b09190c5058f5d831752754e47c8ba7ca84f8d5a by Yufei Cai
Issue #1060: Support GET method in HTTP connections; support x-amz-content-sha256 in AwsRequestSigning.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigningFactory.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigningTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPushValidatorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigning.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPushValidator.java (diff)
Commit 0e1c00f9f2271aa58ee3e71ac0b2853eba7002d7 by Thomas Jaeckle
added a new introduction slide-deck for Eclipse Ditto

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was addeddocumentation/src/main/resources/slides/images/wot.png
The file was addeddocumentation/src/main/resources/slides/2021_05_ditto-introduction-deck/index.html
Commit fa807dbc52ad0035924a82e929ed0c16575c7b64 by Yufei Cai
Issue #1060: Fix xAmzContentSha256 field name; log outgoing HTTP request on DEBUG.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigningFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPublisherActor.java (diff)
Commit 33adbb03002f0b9638ce47089e46be1e908d8f18 by noreply
Remove not needed hyphen in ditto-cluster.yaml
The file was modified deployment/kubernetes/deploymentFiles/ditto/ditto-cluster.yaml (diff)
Commit e15ddb3c2cefaba5d8d0a9782948d99b4effd958 by noreply
Surround env value with double quotation marks
The file was modified deployment/kubernetes/deploymentFiles/ditto/ditto-cluster.yaml (diff)
Commit 9cda28e258f3613ba429c23ed46680defd60e90f by noreply
Fix command to start ditto with another version
The file was modified deployment/kubernetes/README.md (diff)
Commit e0093196f3001d8c3e2e59c7d6c3e8aa725047b4 by Yufei Cai
Issue #1060: Log signed requests on DEBUG level.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPublisherActor.java (diff)
Commit 3a9e9dd4d5f71e963b60d209dac4d09c353e6a16 by Yufei Cai
Connectivity: Improve debug log for incoming messages.

- Log actor ref of response collector for message correlation.

- Add toString() method to MappingOutcome.

- Fix an IndexOutOfBoundException in BaseConsumerActor logging.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/InboundDispatchingActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/ResponseCollectorActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mappingoutcome/DroppedOutcome.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mappingoutcome/ErrorOutcome.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mappingoutcome/MappedOutcome.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseConsumerActor.java (diff)
Commit 559ccc24a142bfe1594dcac4d877da49d5878e66 by Yufei Cai
Fix missing placeholder in debug log.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/InboundDispatchingActor.java (diff)
Commit 1236d912266ab2778c664920287391b9e9a12076 by Johannes Schneider
#586 add configuration for kafka consumer, add migration notes for changed kafka configuration

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was removedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/ProducerPropertiesFactoryTest.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/KafkaConfig.java (diff)
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/PropertiesFactoryTest.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformer.java (diff)
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/ProducerPropertiesFactory.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/DefaultKafkaPublisherActorFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActor.java (diff)
The file was modified connectivity/service/src/test/resources/kafka-test.conf (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/DefaultKafkaProducerFactory.java
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformerTest.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/PropertiesFactory.java
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaConfig.java (diff)
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/DefaultKafkaConnectionFactory.java
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaBootstrapServerSpecificConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActorFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActor.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaProducerFactory.java
The file was modified connectivity/service/src/test/resources/test.conf (diff)
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConnectionFactory.java
The file was addeddocumentation/src/main/resources/pages/ditto/release_notes_210.md
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/ConsumerPropertiesFactory.java
Commit 54ec879e651dabd7e3640cb4503aed5f68a41fcc by Vadim Günther
Fix parameter passing to payload mapper when topic path contains no channel

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was modified connectivity/service/src/main/resources/javascript/outgoing-mapping.js (diff)
Commit 757b851d10da8e72b2d50fea2896e51cc8c7f4d0 by Vadim Günther
Append signature topics with undefined channel

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/connectivity-mapping.md (diff)
The file was modified connectivity/service/src/main/resources/javascript/outgoing-mapping.js (diff)
Commit ac4c07171ae5c12267b80a1622784cc3044e5f09 by Stefan Maute
add logging in case of errors;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/InboundMappingProcessorActor.java (diff)
The file was modified internal/utils/akka/src/main/java/org/eclipse/ditto/internal/utils/akka/controlflow/AbstractGraphActor.java (diff)
Commit c888bf14a98d65184c119f584c22584f03b6aa7b by Stefan Maute
make ThingPersistenceActorMailbox size configurable via env variable;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified things/service/src/main/resources/things.conf (diff)
Commit 0e0020116e2dc7d2ed123fd4e1d338ca029425b0 by Florian Fendt
#1052: correctly deserialize and serialize the parts of a topic for the "none" channel (policies and connections) in the JavaScript mappings

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/connectivity-mapping.md (diff)
The file was modified connectivity/service/src/main/resources/javascript/outgoing-mapping.js (diff)
The file was modified connectivity/service/src/main/resources/javascript/ditto-scope.js (diff)
Commit ce6f4829c50be18117fb4d774616502a6d620a84 by Florian Fendt
#1052: add unit tests verifying correct behaviour of the Ditto JavaScript helper functions for policy and connection announcements

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/connectivity-mapping.md (diff)
The file was modified connectivity/service/src/main/resources/javascript/ditto-scope.js (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/javascript/JavaScriptMessageMapperRhinoTest.java (diff)
Commit c911455d37074e99eb6b51435e2d2a5ac62508c3 by Yufei Cai
Issue #1060: Add missing header for AWS request signing.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigning.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPublisherActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigningTest.java (diff)
Commit cab53d09099c7bf638bbf3d2121bdf18fa35d503 by Stefan Maute
add debug log for dropped signals, if target address can not be resolved;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BasePublisherActor.java (diff)
Commit 2756fdff03837eee5dd52d247ad2a5425e4a7bc5 by Yufei Cai
Issue #1060: render auth parameters without quotes in AwsRequestSigning.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigning.java (diff)
Commit 46d09ee7649b89d056ef150627107dd7390f4051 by Stefan Maute
split log for targets and replayTarget into separate statements;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BasePublisherActor.java (diff)
Commit 16dc84c1ecd4cfcf97f44e32a90c71d3ff93ecdb by Yufei Cai
Issue #1060: Fix AwsRequestSigningTest.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigningTest.java (diff)
Commit 654187f8313ec5bbfb94594c0b3e52e751c40b5a by Dominik Guggemos
#586 use alpakka kafka also for sending messages to kafka cluster, remove dependencies to kafka-clients and kafka-streams, adapt service config and tests

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/PropertiesFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/DefaultKafkaProducerFactory.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaAuthenticationSpecificConfigTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaBootstrapServerSpecificConfigTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/PropertiesFactoryTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaBootstrapServerSpecificConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformer.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaProducerFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaSpecificConfig.java (diff)
The file was modified bom/pom.xml (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActor.java (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaAuthenticationSpecificConfig.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActorTest.java (diff)
The file was modified connectivity/service/src/test/resources/test.conf (diff)
The file was modified connectivity/service/pom.xml (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActorFactory.java (diff)
Commit 5b5686ddfec6b91c096b13fb1c12203f3a963366 by Yufei Cai
Issue #1060: Add reserved HTTP header "http.query" to replace the query string.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPublisherActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPublisherActorTest.java (diff)
Commit c99fa0a454806ad87a344765092477ffe35b01d0 by Vadim Günther
#1060 fix behaviour on empty path. Add unit tests

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigning.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigningTest.java (diff)
Commit 2dc9cda9fbf5682a953e14d16a4aff87145e78a8 by Yufei Cai
Issue #1060: Fix double-appending of "/" to empty paths in AwsRequestSigning.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigning.java (diff)
Commit a0e806387b307e5b8526809e86e28f5f424082a2 by Yufei Cai
Issue #1060: Fix AwsRequestSigningTest again.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigning.java (diff)
Commit 561c485c0377e3cd5903cad8cd08ebd237c43f88 by Stefan Maute
bump nginx version in docker-compose.yml to 1.20-alpine;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified deployment/docker/docker-compose.yml (diff)
Commit 4246d3fa3c63fc415127674dc8a9298e41ee51e5 by Stefan Maute
add initContainer for nginx to wait for gateway to be available before start up;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified deployment/kubernetes/deploymentFiles/nginx/nginx.yaml (diff)
Commit 88074c7cb406135dba98c4cbf9f2665c30f26be7 by Stefan Maute
remove link to /apidoc/1 in index.html in docker and kubernetes;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified deployment/docker/index.html (diff)
The file was modified deployment/kubernetes/deploymentFiles/nginx/index.html (diff)
The file was modified deployment/kubernetes/deploymentFiles/nginx/nginx.conf (diff)
The file was modified deployment/docker/nginx.conf (diff)
Commit a34008d756007b161723d04bb43f0d1a7782e302 by Stefan Maute
add link to resource quota docu;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified deployment/kubernetes/deploymentFiles/resource-quotas/cpu-memory-resource-quota.yaml (diff)
Commit 4c1082f95a0f29d8a64d9d72caf65fb33ae60ac8 by Yufei Cai
Issue #1060: Add HMAC credentials to connection schema.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified documentation/src/main/resources/jsonschema/connection.json (diff)
Commit bd2064553f8b41b84505e2693d225abe54be503d by Yufei Cai
Issue #1060: Document HMAC request signing.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-http.md (diff)
Commit c2e189c15e98519c2b54fad1bf7bc9b93f5304a0 by Dominik Guggemos
#586 add throttling config for kafka consumers, resolve defaults for akka.kafka.consumer and akka.kafka.producer

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/src/test/resources/kafka-test.conf (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/KafkaConfig.java (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaConfigTest.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActor.java (diff)
The file was modified internal/utils/config/src/main/java/org/eclipse/ditto/internal/utils/config/raw/RawConfigSupplier.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaConfig.java (diff)
The file was modified connectivity/service/src/test/resources/test.conf (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/PropertiesFactoryTest.java (diff)
Commit 424995a18fddb92a083a510959cb3c2d8c1a675c by Yufei Cai
Issue #1060: Validate connections with HMAC credentials.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/validation/ConnectionValidator.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/validation/ConnectionValidatorTest.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/validation/CredentialsValidationVisitor.java
Commit 07860ad054b6253e34013ed8a7c950c595f16cdd by Vadim Günther
#1060: Documentation: add GET as new http verb for http1.1 connections

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-http.md (diff)
Commit ba6b7c70c10ab8c173a57d612320395774d57c2b by Dominik Guggemos
#586 add defaults from reference.conf manually (temp. solution)

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformer.java (diff)
The file was modified internal/utils/config/src/main/java/org/eclipse/ditto/internal/utils/config/raw/RawConfigSupplier.java (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActor.java (diff)
Commit 9ee3b77154ce0756a2622b073ce5f64bcfd0eb3e by Vadim Günther
#1060: add documentation entry for "http.query" header mapping

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-http.md (diff)
Commit 1a36e2ad6d1d9bd3e0db79d5c149897991ec2109 by Dominik Guggemos
#586 update to akka 2.6.14

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified bom/pom.xml (diff)
Commit e2c1af945043480ea9ec0890b62e16ad6a22205b by Dominik Guggemos
#586 configure shade plugin to append version.conf files for connectivity service (akka kafka contains another version.conf)

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/pom.xml (diff)
Commit 9616de321a380d34dfc2942b35997556acc1017e by Johannes Schneider
#586 add immutability test and reduced logging for message transformer

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformerTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformer.java (diff)
Commit f2b2844c42554a4715f9c186648961ff83810e7d by Thomas Jaeckle
#1073 reduce logging of JWT parsing/validation errors to not contain stacktrace

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/security/authentication/jwt/DefaultJwtValidator.java (diff)
Commit bf0dc31570fdfd99abc19e85ca050bfa2a37232f by Dominik Guggemos
#586 use defaults from reference.conf

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified internal/utils/config/src/main/java/org/eclipse/ditto/internal/utils/config/raw/RawConfigSupplier.java (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
Commit b50e500a2e4bde69c3ea3d49382701c9a64acadf by Thomas Jaeckle
omit secrets from toString() outputs of Credentials implementations

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified connectivity/model/src/main/java/org/eclipse/ditto/connectivity/model/SshPublicKeyCredentials.java (diff)
The file was modified connectivity/model/src/main/java/org/eclipse/ditto/connectivity/model/ClientCertificateCredentials.java (diff)
The file was modified connectivity/model/src/main/java/org/eclipse/ditto/connectivity/model/UserPasswordCredentials.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/ResponseCollectorActor.java (diff)
Commit 394daebf7591b16cbfe65c366c128e7a8e98c3bb by Stefan Maute
change directory where ditto log files will be created;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified thingsearch/service/src/main/resources/logback.xml (diff)
The file was modified gateway/service/src/main/resources/logback.xml (diff)
The file was modified policies/service/src/main/resources/logback.xml (diff)
The file was modified things/service/src/main/resources/logback.xml (diff)
The file was modified concierge/service/src/main/resources/logback.xml (diff)
The file was modified connectivity/service/src/main/resources/logback.xml (diff)
Commit 76d6a65678b7cfa2f8c1dfda739509b7ecf683e6 by Stefan Maute
change fileNamePattern for TimeBasedRollingPolicy to absolute path;
fix appname in gateway logback.xml;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified thingsearch/service/src/main/resources/logback.xml (diff)
The file was modified policies/service/src/main/resources/logback.xml (diff)
The file was modified connectivity/service/src/main/resources/logback.xml (diff)
The file was modified gateway/service/src/main/resources/logback.xml (diff)
The file was modified concierge/service/src/main/resources/logback.xml (diff)
The file was modified things/service/src/main/resources/logback.xml (diff)
Commit 06f7f81dba787afbc0fdafbc69c7ec2767975535 by Stefan Maute
add log file directory to docker image and grabt ditto user write access;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified dockerfile-snapshot-arm64 (diff)
The file was modified dockerfile-release (diff)
The file was modified dockerfile-snapshot (diff)
Commit 2095d6e649b247e9d3b8cb8210fcc8000dc34525 by Stefan Maute
add env var DITTO_LOGGING_FILE_APPENDER to docker-compose.yml and create volume to access ditto logs on host machine;
add securityContext to ditto-cluster.yaml to enable writing log files to host directory;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified deployment/docker/docker-compose.yml (diff)
The file was modified deployment/kubernetes/README.md (diff)
The file was modified deployment/kubernetes/deploymentFiles/ditto/ditto-cluster.yaml (diff)
Commit b11bff238220a15591a2870555298dee139bab99 by Thomas Jaeckle
don't try to publish ExpiryAnnouncements for new or deleted policies (optimization)

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified policies/service/src/main/java/org/eclipse/ditto/policies/service/persistence/actors/PolicyPersistenceActor.java (diff)
Commit a346b6479d628d23a8fd332035af1e9ea321f6cf by Thomas Jaeckle
fixed imports of ditto-connecticity-model OSGi bundle

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified connectivity/model/pom.xml (diff)
Commit 071c6776eb2b5e10ab7207632351186ac5538124 by Yufei Cai
[#1078] Add AzSaslRequestSigning.

Package placement is deliberate for reuse in AMQP.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified connectivity/service/src/test/resources/test.conf (diff)
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/AzSaslRequestSigningTest.java
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/AzSaslRequestSigning.java
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzSaslRequestSigningFactory.java
Commit c7465b73308c61b1e112ea7302691abf7545baef by Thomas Jaeckle
added (currently failing) test case for enriching MergeEvents with extra fields using the CachingSignalEnrichmentFacade

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified internal/models/signalenrichment/src/test/java/org/eclipse/ditto/internal/models/signalenrichment/CachingSignalEnrichmentFacadeTest.java (diff)
Commit deb77d0144faf2afabfebbd74b50feffff920b2a by Thomas Jaeckle
fixed CachingSignalEnrichmentFacade for ThingMerged events

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified internal/models/signalenrichment/src/main/java/org/eclipse/ditto/internal/models/signalenrichment/CachingSignalEnrichmentFacade.java (diff)
Commit 48b0c4138bf291889eb4d5fc42abbc3941392ab3 by Stefan Maute
fix docker image name;
increase mem_limit for docker containers;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified deployment/docker/docker-compose.yml (diff)
Commit 0c1f0f56a2338af8b8572ea71a523fe36030e45a by Stefan Maute
uncomment resources for easier testing;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified deployment/kubernetes/deploymentFiles/ditto/ditto-cluster.yaml (diff)
Commit c3db98ba2b6af99646a3a5726803a8fbc314a999 by noreply
adjusted example usage of Ditto Java Client

* to reflect API changes to CompletionStages
* to also include `startConsumption()` for receiving live messages
The file was modified documentation/src/main/resources/pages/ditto/client-sdk-java.md (diff)
Commit 706fdfffed96ba580ee0b6914b92bb2b0e6c5185 by Yufei Cai
[#1078] Add option to set SR in AzSaslRequestSigning.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzSaslRequestSigningFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/AzSaslRequestSigning.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/AzSaslRequestSigningTest.java (diff)
Commit 610af89742b8400a19e00fae9a5b5b15081c7cc6 by Thomas Jaeckle
Enable separate configuration for minimum reconnect delay for MQTT broker initiated disconnects of MQTT sessions
* by default, 0ms were applied for those as well which might not be a good default and "DoS" MQTT brokers

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/AbstractMqttClientActor.java (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultMqttConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/MqttConfig.java (diff)
Commit 2bf2330083a2165d6855fe89d8ff9449faaa1f7c by Yufei Cai
[#1078] rename "sr" to "endpoint" in AzSaslRequestSigning.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/AzSaslRequestSigning.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzSaslRequestSigningFactory.java (diff)
Commit 33db2f0297cbc24f36c8297bba907795d91b126a by Thomas Jaeckle
fixed test.conf

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified connectivity/service/src/test/resources/test.conf (diff)
Commit 8ebf359dfd4d5761da43458df0284861408bade2 by Thomas Jaeckle
fixed connection-test.conf

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified connectivity/service/src/test/resources/connection-test.conf (diff)
Commit 2f194eac05d890e0155554b94559850351328afb by Yufei Cai
[#1078] Make "endpoint" of AzSaslRequestSigning mandatory.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/AzSaslRequestSigning.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzSaslRequestSigningFactory.java (diff)
Commit dd2837c306f31956e1e495a2dfb5a33d9be0b3d5 by Yufei Cai
[#1078] Allow AzSaslRequestSigning to authenticate AMQP 1.0 connections.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpSpecificConfig.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/AzSaslRequestSigningTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpSpecificConfigTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpClientActor.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/SaslPlainCredentialsSupplier.java
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/AbstractBaseClientActorTest.java (diff)
The file was modified things/service/src/main/java/org/eclipse/ditto/things/service/starter/ThingsService.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/starter/SearchService.java (diff)
The file was modified base/service/src/main/java/org/eclipse/ditto/base/service/DittoService.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/ConnectivityRootActorTest.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/starter/ConciergeService.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/PlainCredentialsSupplier.java
The file was modified policies/service/src/main/java/org/eclipse/ditto/policies/service/starter/PoliciesService.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/ConnectionBasedJmsConnectionFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/DefaultClientActorPropsFactory.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/starter/GatewayService.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/DefaultClientActorPropsFactoryTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/persistence/ConnectionPersistenceOperationsActorIT.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/RequestSigningExtension.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/validation/CredentialsValidationVisitor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/ConnectivityService.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpClientActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/AzSaslRequestSigning.java (diff)
Commit 2e1ecdd40a99ed96e2b6630d45577df2988012de by Yufei Cai
[#1078] Make JSON field definitions of request signing factories final.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzMonitorRequestSigningFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigningFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzSaslRequestSigningFactory.java (diff)
Commit 6cbc2fd15ec5a99e29c7632e095c6f8a26589e18 by Yufei Cai
[#1078] Fix ConnectionValidatorTest.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/validation/ConnectionValidatorTest.java (diff)
Commit 816cab0627a913d85f3e37df1a1676f78e9f09f8 by Stefan Maute
add pod to initialize ditto logs directory on host vm;
extend securityContext with user and group;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was addeddeployment/kubernetes/deploymentFiles/ditto/ditto-log-files.yaml
The file was modified deployment/kubernetes/deploymentFiles/ditto/ditto-cluster.yaml (diff)
The file was modified deployment/kubernetes/README.md (diff)
Commit fcfc574e40480ac3114a7671f6ebd000b0866ce5 by Stefan Maute
use gid 1000 for ditto group;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified dockerfile-release (diff)
The file was modified dockerfile-snapshot-arm64 (diff)
The file was modified dockerfile-snapshot (diff)
Commit f89eea01d0a3527814e6049adca3eeda5287fcab by Yufei Cai
[#1078] Fix AMQP username of AzSaslRequestSigning.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpSpecificConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/AzSaslRequestSigning.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/AzSaslRequestSigningTest.java (diff)
Commit e56d304059af24e5ce66892507e4bd63c349a155 by Yufei Cai
[#1078] use DittoDuration format for AzSaslRequestSigning's ttl parameter.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzSaslRequestSigningFactory.java (diff)
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzSaslRequestSigningFactoryTest.java
Commit a49fb645e038f43ab3045ada10ecfd26d5bc201e by Stefan Maute
rename volume for ditto log files;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified deployment/kubernetes/deploymentFiles/ditto/ditto-cluster.yaml (diff)
The file was modified deployment/kubernetes/deploymentFiles/ditto/ditto-log-files.yaml (diff)
Commit f1cb137bc070b8f2cb4b6aa470d667cd6f051cf8 by Stefan Maute
add prerequisite to documentation for ditto log files;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/installation-operating.md (diff)
The file was modified deployment/kubernetes/README.md (diff)
Commit 13a79c57897b9a93fbd39bb3049d47625e1f39b2 by Dominik Guggemos
#586 ignore duplicate headers (log warning only), clean up connectivity.conf

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformer.java (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified internal/utils/config/src/main/java/org/eclipse/ditto/internal/utils/config/raw/RawConfigSupplier.java (diff)
Commit 45996768e2102ac671b12f7052c88b11d178b13c by Yufei Cai
[#1078] set default TTL of az-sasl to 1 week to prevent cascading backoff.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzSaslRequestSigningFactory.java (diff)
Commit 525105a8020b1440a06f3dc21f5065c8bad8f201 by Yannic Klem
Filter expired messages based on creation-time and ttl headers

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java (diff)
Commit c2868c22b45d8537866bf73f86034936a413b7e7 by Johannes Schneider
#586 add entity placeholders to resolver creators to use in kafka targets

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/Resolvers.java (diff)
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/ResolversTest.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActor.java (diff)
Commit 2ca16619a5dda4a514a69b595da32d5d4d721c29 by Florian Fendt
[#1078] provide actorSystem in ClientActorPropsFactory#getActorPropsForType instead of having it in every DittoService

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/starter/GatewayService.java (diff)
The file was modified policies/service/src/main/java/org/eclipse/ditto/policies/service/starter/PoliciesService.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzSaslRequestSigningFactory.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/ConnectivityRootActorTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/persistence/ConnectionPersistenceOperationsActorIT.java (diff)
The file was modified base/service/src/main/java/org/eclipse/ditto/base/service/DittoService.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/starter/ConciergeService.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/DefaultClientActorPropsFactoryTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/RequestSigning.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/MockClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/ConnectivityService.java (diff)
The file was modified things/service/src/main/java/org/eclipse/ditto/things/service/starter/ThingsService.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/ClientActorPropsFactory.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/FaultyClientActor.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/starter/SearchService.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/DefaultClientActorPropsFactory.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/AbstractBaseClientActorTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/ErrorHandlingActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/RequestSigningFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/validation/DittoConnectivityCommandValidator.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
Commit 2cb4fb9a0a145eecfeb4897d35a12bec4eb62801 by Johannes Schneider
#586 add dispatcher for alpakka kafka

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
Commit a023f3c10a238bf9c86c73ea3af52f5fa0494d90 by Johannes Schneider
#586 use dispatcher only for consuming messages from kafka

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
Commit 7ef33cb300c01aa53e8245f265bf2a274a4f8855 by Florian Fendt
[#1078] add test for SaslPlainCredentialsSupplier

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpSpecificConfigTest.java (diff)
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/amqp/SaslPlainCredentialsSupplierTest.java
Commit 584183c4e346797f09deacb6f20bcb477fcaf13a by Florian Fendt
[#1078] split request signing factories into different factories for http push and amqp

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/PlainCredentialsSupplier.java (diff)
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/NoOpRequestSigning.java
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpConnectionSigningFactory.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzMonitorRequestSigningFactory.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpRequestSigningExtension.java
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpRequestSigningFactory.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzMonitorRequestSigning.java (diff)
The file was removedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/AzSaslRequestSigningTest.java
The file was modified connectivity/service/src/test/resources/amqp10-test.conf (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/signing/AzSaslSigningFactory.java
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpConnectionSigning.java
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/amqp/SaslPlainCredentialsSupplierTest.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpConnectionSigningExtension.java
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpRequestSigning.java
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/signing/NoOpSigning.java
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzSaslRequestSigningFactory.java
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/config/DefaultAmqp10ConfigTest.java
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/WithStringMapDecoding.java
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/AzSaslSigningTest.java
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzSaslSigningFactoryTest.java
The file was removedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/config/DefaultAmqp10ConfigTest.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/Amqp10Config.java (diff)
The file was removedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AzSaslRequestSigningFactoryTest.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultAmqp10Config.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/signing/Signing.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultHttpPushConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigningFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigning.java (diff)
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/RequestSigning.java
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/AzSaslRequestSigning.java
The file was modified connectivity/service/src/test/resources/test.conf (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/SaslPlainCredentialsSupplier.java (diff)
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/RequestSigningExtension.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPublisherActor.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/signing/AzSaslSigning.java
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/RequestSigningFactory.java
Commit 556a6d938ce63aa0e7a636cbe5e154717a340cd6 by Stefan Maute
create $DITTO_HOME and $DITTO_LOGS directory inside the one RUN directive for all dockerfiles;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified dockerfile-snapshot-arm64 (diff)
The file was modified dockerfile-release (diff)
The file was modified dockerfile-snapshot (diff)
Commit b3a8156d1cfad9923f54d0fddc25e543d705d5c1 by Yannic Klem
Add documentation for kafka sources

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-kafka2.md (diff)
Commit 8e5754c5ece688d6740dd5cfb6139e7c87f67f5a by Florian Fendt
[#1078] fix DefaultAmqp10ConfigTest

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/config/DefaultAmqp10ConfigTest.java (diff)
Commit fa59422304b77f7bcf0ba941d21d731ed82d7ba8 by Yufei Cai
[#1078] Remove test to not verify SSL certificates.

Reason: Not possible to test uniformly for all protocols.
Kafka connections do not check certificate during connection test.
AMQP connections time out when tested against an HTTP server.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/AbstractBaseClientActorTest.java (diff)
Commit 5fff3e57b56596ecb30e211e3c2dda1878267bc0 by Yufei Cai
[#1078] Restore support of client-certificate credentials with basic-auth for SaslPlainCredentialsSupplier.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/amqp/SaslPlainCredentialsSupplierTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/SaslPlainCredentialsSupplier.java (diff)
Commit 56eef15a26b19ad7ffccc0a91f7dc4c5b8c0af24 by Dominik Guggemos
#586 suffix kafka consumer/producer client ids

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/PropertiesFactory.java (diff)
Commit 292dc1469e3f368d41bf875fe0a439c751569503 by Florian Fendt
[#1078] move documentation on HMAC signing onto extra page and reference it from HTTP and AMQP 1.0 bindings.

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was addeddocumentation/src/main/resources/pages/ditto/connectivity-hmac-signing.md
The file was modified documentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-http.md (diff)
The file was modified documentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-amqp10.md (diff)
Commit 4771053d9640bf2b697acf05660b1cc4a68cb0ba by Florian Fendt
[#1078] add blog post for HMAC signing for HTTP push and AMQP connections

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was addeddocumentation/src/main/resources/_posts/2099-01-01-hmac-credentials.md
Commit ca08e0658f09466017241c9fdd3ee1809bcf06e9 by Thomas Jaeckle
fix rounding up "policyExpiryGranularity" to "0" (disabling it)
* this caused an arithmetic error before as "modulo 0" was done

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified policies/service/src/main/java/org/eclipse/ditto/policies/service/persistence/actors/strategies/commands/AbstractPolicyCommandStrategy.java (diff)
The file was modified policies/service/src/main/java/org/eclipse/ditto/policies/service/persistence/actors/PolicyPersistenceActor.java (diff)
The file was modified policies/service/src/test/java/org/eclipse/ditto/policies/service/persistence/actors/strategies/commands/SubjectExpiryAdjustmentTest.java (diff)
Commit 202dc975438437c5e700b38060c71917cce64301 by Stefan Maute
update installation-operating.md;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/installation-operating.md (diff)
Commit 03b25083b549fdcb16bb2d328ed3b1bbb2129746 by Florian Fendt
[#1078] update little parts on the documentation of HMAC algorithms

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified documentation/src/main/resources/_posts/2099-01-01-hmac-credentials.md (diff)
The file was modified documentation/src/main/resources/pages/ditto/connectivity-hmac-signing.md (diff)
Commit 5af46241f1215a7ce2c972bdfef6338a279e1ff7 by Florian Fendt
[#1078] fix how AMQP connections handle the validateCertificates configuration, which was causing timeouts when connecting to a secured resource with validateCertificates=false. Also re-add the 'testTLSConnectionWithoutCertificateCheck' which verifies the correct behavior for this.

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/ConnectionBasedJmsConnectionFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpRequestSigning.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpConnectionSigning.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/signing/Signing.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/DefaultHttpPushFactory.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/AbstractBaseClientActorTest.java (diff)
Commit ae2a0b8ccc6e4123be4226adb0d392c8544ec3e3 by Florian Fendt
[#1078] add HMAC signing to sidebar and include examples section

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/connectivity-hmac-signing.md (diff)
The file was modified documentation/src/main/resources/_posts/2099-01-01-hmac-credentials.md (diff)
The file was modified documentation/src/main/resources/_data/sidebars/ditto_sidebar.yml (diff)
Commit ffac87e88110a8f9270956c55fbb5aead23d6cad by Yufei Cai
[#1060] Connectivity: Add reserved header http.path to set the path of outgoing HTTP requests.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPublisherActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPublisherActorTest.java (diff)
The file was modified documentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-http.md (diff)
Commit 040804a3c3894ec50e4ff089199434758063b19d by Dominik Guggemos
#586 drop consumed messages in dry run mode, disable auto commit in dry run mode

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/PropertiesFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/PropertiesFactoryTest.java (diff)
Commit a1073cbc534aa7ce2afde2a0663df46444c0b3b9 by Yufei Cai
[#1078] Fix typos.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/connectivity-hmac-signing.md (diff)
Commit 74c8ff0c4ec6ad5189b292baeda72c09dc25f3a0 by Thomas Jaeckle
stabilize coordinated shutdown hook in BaseClientActor for sending connection announcements:
* shut down client actor after sending close announcement as part of coordinated shutdown
* only add coordinated shutdown hook for connections actually requesting connection announcements
* configured default "disconnecting-max-timeout" to "5s" instead of 60s as before
* added ImmutableClientDisconnected class and implemented toString() correctly in all subclasses of AbstractWithOrigin

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPushClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/internal/ClientDisconnected.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ClientConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/internal/ImmutableConnectionFailure.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/JMSConnectionHandlingActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/amqp/JmsConnectionHandlingActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/AbstractMqttClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/internal/ImmutableClientDisconnected.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/rabbitmq/RabbitMQClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/internal/AbstractWithOrigin.java (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
Commit 7de659937a838ff514c7f198864a1d5c097e3f98 by Thomas Jaeckle
update Akka to 2.6.15 and Akka Management to 1.1.0

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified bom/pom.xml (diff)
Commit 49a0c5e025272186ec646befdc23b7da7503a14f by Johannes Schneider
#586 use streams to publish messages to kafka

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified connectivity/service/src/test/resources/kafka-test.conf (diff)
The file was modified connectivity/service/src/test/resources/test.conf (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/DefaultKafkaPublisherActorFactoryTest.java (diff)
The file was removedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActorTest.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/DefaultKafkaPublisherActorFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActorFactory.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/KafkaConfig.java (diff)
Commit 14e7bbe47345de7e01d0bbe6d92eddf54b3c07e5 by Johannes Schneider
#586 fix test

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaConfig.java (diff)
Commit 1c86e7130dfd54f965112fe8171bb80b0f80be97 by Thomas Jaeckle
fix HttpPushFactoryTest by using a parallelism with power of 2

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPushFactoryTest.java (diff)
Commit 9835f42b664adab744f0a50a7ab7d57f8bbac5cd by Thomas Jaeckle
adjusted gateway.conf to let "service-requests-done" coordinated shutdown phase timeout be 12s, 2s longer than the "ditto.gateway.http.coordinated-shutdown-timeout"

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified gateway/service/src/main/resources/gateway.conf (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
Commit f5493ff37b15085e2f13579115c4b195668a6378 by Thomas Jaeckle
try to fix EnformcentFlowTest

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified thingsearch/service/src/test/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/EnforcementFlowTest.java (diff)
Commit 8d3248c8a150364e8a2172906f7777c089e34e85 by Yufei Cai
[#1060] Adjust AwsRequestSigning to support S3 better.

S3 singly encodes path string except '/' and '.' in
the canonical request.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigningTest.java (diff)
The file was modified base/service/src/main/java/org/eclipse/ditto/base/service/UriEncoding.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/AwsRequestSigning.java (diff)
Commit 59390bc457e59e7b42e554dc14d8fb84d32ba576 by Yufei Cai
[#1078] Add cloud integration examples using HMAC.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/connectivity-hmac-signing.md (diff)
Commit bfbba8015c3e63ce1202daf2c366c24f68d9382d by Thomas Jaeckle
fixed EnforcementFlow parallelism

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified thingsearch/service/src/test/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/EnforcementFlowTest.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/EnforcementFlow.java (diff)
Commit a6bc36d0712606c8d88c9b48baf8e4cbc4b2184f by Yannic Klem
Fix naming

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java (diff)
Commit 7c17b08db0f28df74a181ef12a9682a24ff1df80 by Thomas Jaeckle
downgrade to Akka 2.6.14 again after Akka streams has some changes (or even a bug) to attribute propagation which could lead to a very different behavior

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified bom/pom.xml (diff)
Commit 21be3532d0d7c9af35dbda32e352238fd40511ec by Stefan Maute
enable POST, PUT and DELETE requests for akka management api;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified base/service/src/main/java/org/eclipse/ditto/base/service/DittoService.java (diff)
The file was modified internal/utils/config/src/main/resources/ditto-akka-config.conf (diff)
Commit e8db64d76cf223e611cccae6b540ddad49c3c878 by Florian Fendt
[#1088] retry starting BaseClientActors when they fail when being started by the ConnectionPersistenceActor. Escalate failures of the router pool to the supervisor actor which can restart the ConnectionPersistenceActor.

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultConnectionConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/ClientActorRefs.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/config/DefaultConnectionConfigTest.java (diff)
The file was modified connectivity/service/src/test/resources/test.conf (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/persistence/OneForOneEscalateStrategy.java
The file was modified connectivity/service/src/test/resources/connection-test.conf (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectionConfig.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/persistence/OneForOneEscalateStrategyTest.java
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
Commit 8d3e8887e53acbc0cb5311d7426a880f4bccf689 by Thomas Jaeckle
updated to Akka 2.6.15 again and fixed EnforcementFlowTest

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified bom/pom.xml (diff)
The file was modified thingsearch/service/src/test/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/EnforcementFlowTest.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/EnforcementFlow.java (diff)
Commit a2522e61f8bc829908211defb653d88f304abc56 by Dominik Guggemos
#586 use SendProducer instead of Producer.flexiFlow() to be able to handle the publish errors/acknowledgfements correctly, re-enabled KafkaPublisherActorTest

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActorFactory.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/SendProducerFactory.java
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/MockSendProducerFactory.java
The file was modified connectivity/service/src/test/resources/kafka-test.conf (diff)
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaProducerFactory.java
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/DefaultSendProducerFactory.java
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/DefaultKafkaProducerFactory.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/DefaultKafkaPublisherActorFactory.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActor.java (diff)
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActorTest.java
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageContext.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaConfig.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaConfigTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActor.java (diff)
The file was modified connectivity/service/src/test/resources/test.conf (diff)
Commit 4568b508456b33f4bee75dfeb19ae3893149214c by Thomas Jaeckle
don't remove all other addresses in ClusterMemberRemovedAware when own instance was terminated
* don't log error in Subscriber watchign Termination when own instance was terminated

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified internal/utils/pubsub/src/main/java/org/eclipse/ditto/internal/utils/pubsub/actors/Subscriber.java (diff)
The file was modified internal/utils/pubsub/src/main/java/org/eclipse/ditto/internal/utils/pubsub/actors/ClusterMemberRemovedAware.java (diff)
Commit 2640ee2e0ef0a5511855da0bb2efeb8d17916171 by Dominik Guggemos
#586 move producer config to producer section

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
Commit d42ade8d8365c12e7b0592668ece039dbf623c65 by Thomas Jaeckle
remove non needed Attributes inputBuffer on EnforcementFlow

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/EnforcementFlow.java (diff)
Commit 838e25face254a0c44f69cb2916be12d4f2c3eea by Thomas Jaeckle
review: made OneForOneEscalateStrategy final + minor javadoc addition

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/persistence/OneForOneEscalateStrategyTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/persistence/OneForOneEscalateStrategy.java (diff)
Commit 20b3b4071bbddf777fce3a67901957f89f2a1bae by Johannes Schneider
#586 send connection failure message to parent if kafka producer stream fails

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActor.java (diff)
Commit 3d86374d67b9ff1e6f93c519d1641ed547c0e0e0 by Dominik Guggemos
#586 disable parallel publishing, use separate dispatcher for publishing

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActor.java (diff)
Commit 93ebff5529babb253aeb83328e3d60b4db21ea15 by Florian Fendt
[#1078] rewrite Azure IoT Hub example payload mapping to map the ditto protocol message to a direct method

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/connectivity-hmac-signing.md (diff)
The file was modified documentation/src/main/resources/_posts/2099-01-01-hmac-credentials.md (diff)
Commit 3e0d34e7d6419d8520426dca51e222b560cc8920 by Florian Fendt
[#1078] fix use of jekylls %raw% in markdown

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/connectivity-hmac-signing.md (diff)
Commit e2ef148718890dd87cbeac28dc2de3bcbd0143a2 by Thomas Jaeckle
adjusted "role" for all splitBrain resolver configs to be unset
* that causes that a split brain situation is detected by looking at all instances of the Ditto cluster and not by looking at a single cluster role (the one of the SBR "leader")

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified thingsearch/service/src/main/resources/things-search.conf (diff)
The file was modified policies/service/src/main/resources/policies.conf (diff)
The file was modified things/service/src/main/resources/things.conf (diff)
The file was modified gateway/service/src/main/resources/gateway.conf (diff)
The file was modified concierge/service/src/main/resources/concierge.conf (diff)
Commit 66cde9c7dc0791727eb107b898dc19e34e179d1e by Florian Fendt
[#1078] add az-sasl to connection json in the documentation

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified documentation/src/main/resources/jsonschema/connection.json (diff)
The file was modified documentation/src/main/resources/pages/ditto/connectivity-hmac-signing.md (diff)
Commit dab3c0bc6182148269766a019286b8f0dbb3891e by Yannic Klem
Adjust documentation for kafka sources

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-kafka2.md (diff)
Commit 84d1557111d342b3dff9bae20db4baa9c1c0fbc8 by Dominik Guggemos
#586 add dedicated kafka dispatcher also for unit tests

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/src/test/resources/test.conf (diff)
Commit 268fd7da481a75a7dcb3c574627b74b9b5ee2a14 by Thomas Jaeckle
configure "least-shard-allocation-strategy" algorithm in order to get better shard allocation / rebalancing

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified internal/utils/config/src/main/resources/ditto-akka-config.conf (diff)
Commit 26a307d3d5c7bac45dc9aa1ed8b6415958187e61 by Thomas Jaeckle
downgrade Akka version to 2.6.13

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified bom/pom.xml (diff)
Commit cc62a03fd6ca54ac3c93aa4b954a1599290776f6 by Florian Fendt
[#1078] align az-sasl hmac signing examples with the previous examples

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/connectivity-hmac-signing.md (diff)
Commit fd9f8e309359090a7fdad67398ca3b4fc2890de0 by Florian Fendt
[#1060] test all paths of reserved headers in HttpPublisherActor

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPublisherActorTest.java (diff)
Commit 3cc374870d40fc49720011564c87af4a6d6d8e9f by Johannes Schneider
#586 restart source if stream fails

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActor.java (diff)
Commit 58f505448932417851ed981f06e19a47184962f0 by Thomas Jaeckle
downgrade Akka Management version to 1.0.10

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified bom/pom.xml (diff)
Commit 306e4ce445eabb7c45a1fe65c9f1970549d29d33 by Dominik Guggemos
#586 drop consumed messages in dry run mode, disable auto commit in dry run mode

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/src/test/resources/test.conf (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActor.java (diff)
Commit cdf66247f93d0d436368cd4ad0bd5fbaf8114569 by Johannes Schneider
#586 make kafka producer restart backoff configurable

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaConfigTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/KafkaConfig.java (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified connectivity/service/src/test/resources/test.conf (diff)
The file was modified connectivity/service/src/test/resources/kafka-test.conf (diff)
Commit 7df839bdb1dc7a22b7d0f5e8e2a48c1fe3260ab9 by Dominik Guggemos
#586 fix KafkaPublisherActorTest

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/pom.xml (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/MockSendProducerFactory.java (diff)
The file was modified bom/pom.xml (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActor.java (diff)
Commit e2e96904b31b37bd0e61f746446b2f89160e1fad by Thomas Jaeckle
gracefully shutdown logback-classic logging in DittoService during coordinated shutdown
* updated logstash-logback forwarder to 6.6
* configured "reconnectionDelay" to logstash to "1 second"
* configured "logstash-logback-encoder" dependency to be included on "runtime" Maven scope
* adjusted coordinated shutdown phase of SshClientProvider to be not in the last phase, but 1 earlier
* increased coordinated shutdown "cluster-exiting" timeout to 20s

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified internal/utils/config/src/main/resources/ditto-akka-config.conf (diff)
The file was modified connectivity/service/pom.xml (diff)
The file was modified things/service/pom.xml (diff)
The file was modified policies/service/src/main/resources/logback.xml (diff)
The file was modified gateway/service/pom.xml (diff)
The file was modified things/service/src/main/resources/logback.xml (diff)
The file was modified thingsearch/service/pom.xml (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/tunnel/SshClientProvider.java (diff)
The file was modified bom/pom.xml (diff)
The file was modified gateway/service/src/main/resources/logback.xml (diff)
The file was modified thingsearch/service/src/main/resources/logback.xml (diff)
The file was modified concierge/service/src/main/resources/logback.xml (diff)
The file was modified policies/service/pom.xml (diff)
The file was modified base/service/src/main/java/org/eclipse/ditto/base/service/DittoService.java (diff)
The file was modified concierge/service/pom.xml (diff)
The file was modified connectivity/service/src/main/resources/logback.xml (diff)
Commit 3ed9b8c4267664489d5cb1f5a207e767822939df by Stefan Maute
add debug log to postStop method;
fix sonar warnings;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java (diff)
Commit 7b2eb148514005a46ade81a2b6df851c164aaf3c by Yannic Klem
Adds entity placeholder for http push target path

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPushValidator.java (diff)
Commit d927f6517065776cc40e9c6d011063a309c2e2fd by Johannes Schneider
#586 make kafka producer restart backoff configurable, move config for alpakka into separate config inside of consumer and producer, implemented config model for consumer and producer

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/KafkaConsumerConfig.java
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaProducerConfigTest.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaProducerConfig.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/DefaultKafkaPublisherActorFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/KafkaConfig.java (diff)
The file was modified connectivity/service/src/test/resources/test.conf (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaConfigTest.java (diff)
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaConsumerConfigTest.java
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaConfig.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaConsumerConfig.java
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActorFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/PropertiesFactory.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/KafkaProducerConfig.java
The file was modified connectivity/service/src/test/resources/kafka-test.conf (diff)
Commit 80a5827cb5c2c74cc7fb22edf7335bda79a1bbb3 by Dominik Guggemos
#586 wrap kafka send result in source and use flatmap to fail the source and restart it

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActor.java (diff)
Commit 3340ef1987efeb31bec0aa7cec3b19aa33a0b1f1 by Johannes Schneider
#586 recreate send producer and source queue when the producer stream is restarted

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActor.java (diff)
Commit 7859b4abb5789ddc926ea7818aa9df9112560a9b by Johannes Schneider
#586 fix config file for tests

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modified connectivity/service/src/test/resources/test.conf (diff)
Commit ab2cb55528e023297aa56a5489f652b5d32b65a9 by Johannes Schneider
#586 fix wrong parentheses in connectivity config

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified connectivity/service/src/test/resources/test.conf (diff)
Commit bcee3a7c3775e0454ea4441fc1a6b48710666f65 by Thomas Jaeckle
to rule out runtime classnotfound errors, put janio back to "compile" scope
* re-adjusted "cluster-exiting" timeout to 10s

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified concierge/service/pom.xml (diff)
The file was modified things/service/pom.xml (diff)
The file was modified internal/utils/config/src/main/resources/ditto-akka-config.conf (diff)
The file was modified policies/service/pom.xml (diff)
The file was modified thingsearch/service/pom.xml (diff)
The file was modified gateway/service/pom.xml (diff)
The file was modified connectivity/service/pom.xml (diff)
Commit 1f3ba399cebdd1b5ccf102f9d0d2cbac71db69b2 by Johannes Schneider
#586 fix more wrong parentheses in connectivity config

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
Commit c0582c897fef15f08bc376f572bd0a3c08b54944 by Stefan Maute
log shutdown reason;
stop AkkaManagement in Coordinated Shutdown phase;
stop loggerContext in PhaseActorSystemTerminate phase;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified base/service/src/main/java/org/eclipse/ditto/base/service/DittoService.java (diff)
Commit c6877c1b329ab8ef32a71bbad2ca1ba4bb44c29b by Stefan Maute
return completionStage from AkkaManagement.stop();
fix coordinatedShutdown reason;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified base/service/src/main/java/org/eclipse/ditto/base/service/DittoService.java (diff)
Commit 3d9f674ddb4322737624c759b3f0f852a1a01a1f by Yufei Cai
[#1078] Documentation: Replace "message name" by "message subject" for consistency.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified documentation/src/main/resources/_posts/2099-01-01-hmac-credentials.md (diff)
The file was modified documentation/src/main/resources/pages/ditto/connectivity-hmac-signing.md (diff)
Commit 1cba65f09264b7cb9e4834c7683fa8f7eb7ca1f9 by Yufei Cai
[#1078] date hmac blogpost.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was removeddocumentation/src/main/resources/_posts/2099-01-01-hmac-credentials.md
The file was addeddocumentation/src/main/resources/_posts/2021-06-17-hmac-credentials.md
Commit 0440a4f73ac3de5bac0aa36b06e0fc1f98d66607 by Dominik Guggemos
#586 use RestartFlow instead of RestartSource to keep the source queue and restart only the publishing flow, fix handling queue offer result (also for amqp publisher)

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/MockSendProducerFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpPublisherActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActorTest.java (diff)
Commit a3498b38571474b7e14f0fbd0f93ce582e30154c by Yufei Cai
[#1078] Give testTLSConnectionWithoutCertificateCheck more time; remove actor system contamination between tests.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpClientActorTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/AbstractBaseClientActorTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/rabbitmq/RabbitMQClientActorTest.java (diff)
Commit 5091725c919e1ade6fb93024f111826f011d4812 by Yufei Cai
stabilize coordinated shutdown hook in BaseClientActor for sending connection announcements:
* shut down client actor after sending close announcement as part of coordinated shutdown
* only add coordinated shutdown hook for connections actually requesting connection announcements
* configured default "disconnecting-max-timeout" to "5s" instead of 60s as before
* added ImmutableClientDisconnected class and implemented toString() correctly in all subclasses of AbstractWithOrigin

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/amqp/JmsConnectionHandlingActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ClientConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/internal/ClientDisconnected.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/AbstractMqttClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/internal/AbstractWithOrigin.java (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActor.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/internal/ImmutableClientDisconnected.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPushClientActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/JMSConnectionHandlingActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/internal/ImmutableConnectionFailure.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/rabbitmq/RabbitMQClientActor.java (diff)
Commit f86356188a23f234a0bd82684088cb0be7e2c43f by Stefan Maute
set allowed clock skew to 10 seconds to tolerate discrepancy when verifying local time against exp and nbf claims in JWT;
add unit tests;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/security/authentication/jwt/DefaultJwtValidator.java (diff)
The file was modified gateway/service/src/test/java/org/eclipse/ditto/gateway/service/security/authentication/jwt/JwtValidatorTest.java (diff)
The file was modified gateway/service/src/test/java/org/eclipse/ditto/gateway/service/security/authentication/jwt/JwtTestConstants.java (diff)
Commit fca35d23a717cbd845311c97dc6819713165a282 by Yannic Klem
Add setter for multiple subjects at once

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modified policies/model/src/main/java/org/eclipse/ditto/policies/model/Subjects.java (diff)
The file was modified policies/model/src/main/java/org/eclipse/ditto/policies/model/ImmutableSubjects.java (diff)
Commit b3b99895c1a8c9ae5e94daf4025dced715287f6e by Dominik Guggemos
#586 add test to verify usage of entity:id placeholder in http push target

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPushValidatorTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPublisherActorTest.java (diff)
Commit f2ec5f7bcafbd48468732361c895d83ac6bc49c9 by Dominik Guggemos
#586 remove some debug statements

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaPublisherActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpPublisherActorTest.java (diff)
Commit e27cda59c8d10cebbcf7a264f0e6e67b7f3f5afa by Thomas Jaeckle
added slidedeck for Ditto 2.0 release notes + roadmap

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/presentations.md (diff)
The file was addeddocumentation/src/main/resources/slides/2021_06_ditto-20-overview/index.html
Commit 739e5f1b54453f667962957ba4582f89219ec1ef by Stefan Maute
add new config key 'allowed-clock-skew' to oauth config;
extend OAuthConfig interface and DefaultOAuthConfig;
use new config value in DefaultJwtValidator;
add unit tests;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/security/authentication/jwt/DefaultJwtValidator.java (diff)
The file was modified gateway/service/src/test/java/org/eclipse/ditto/gateway/service/util/config/security/DefaultOAuthConfigTest.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/util/config/security/OAuthConfig.java (diff)
The file was modified gateway/service/src/test/resources/oauth-test.conf (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/util/config/security/DefaultOAuthConfig.java (diff)
The file was modified gateway/service/src/test/java/org/eclipse/ditto/gateway/service/security/authentication/jwt/JwtValidatorTest.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/security/authentication/jwt/JwtAuthenticationFactory.java (diff)
The file was modified gateway/service/src/main/resources/gateway.conf (diff)
Commit 528b0a0fd859f1cc9fa4a11b20d3fffd53361ec6 by Johannes Schneider
add unit test for setSubjects, add @since tag

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modified policies/model/src/main/java/org/eclipse/ditto/policies/model/ImmutableSubjects.java (diff)
The file was modified policies/model/src/test/java/org/eclipse/ditto/policies/model/ImmutableSubjectsTest.java (diff)
The file was modified policies/model/src/main/java/org/eclipse/ditto/policies/model/Subjects.java (diff)
Commit e2dd6b71f0cf77afc3d21cfc6aa5b849edd492dc by Johannes Schneider
fix todo, remove unused import

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java (diff)
Commit 0580b3cc0d63f336020dea08f3e1bdafb3e51846 by Johannes Schneider
fix license header

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageContext.java (diff)
Commit 9a0809482d05cd8fe8fbc71a6274505310e89b90 by noreply
configure mongodb circuit breaker timeout higher

current setting was not applied for "policies" + "things"
The file was modified internal/utils/persistence/src/test/java/org/eclipse/ditto/internal/utils/persistence/mongo/ops/eventsource/MongoEventSourceITAssertions.java (diff)