SuccessChanges

Summary

  1. Use varargs for constructor parameter to make super constructor calls (details)
  2. Added convenience method for getting instance with warn level. (details)
  3. Consolidate persistence actor supervision in (details)
  4. Extract results of persistent actor command strategies into a utility. (details)
  5. Extract persistent actor command strategies into a utility. (details)
  6. Extract persistent actor event strategies into a utility. (details)
  7. Extract common behavior of persistent actor into an abstract class. (details)
  8. Refactor policy persistence actor using (details)
  9. [wip] Refactor ConnectionActor to compilable state. (details)
  10. Make strategy context dynamic. (details)
  11. ConnectionActor: validate test and modify commands, check for activity. (details)
  12. ConnectionActor: Handle actions and forward signals. (details)
  13. Fix ModifyConnectionResponseTest. (details)
  14. Fix tests, cleanup code. (details)
  15. Rearrange code, fix TODOs, add javadoc. (details)
  16. Restore accidentally removed overloaded method. (details)
  17. Fix etag handling of CreatePolicy and CreateThing (details)
  18. ETag handling: split entity extractor between previous and next state. (details)
  19. Add connection type http-push and its config, validator and publisher. (details)
  20. remove double semicolon (details)
  21. added release notes for milestone 1.0.0-M1a (details)
  22. reverted unintended change to old blog post (details)
  23. Implement basic functionalities to ConnectionStatusMapper (details)
  24. added sonarqube analysis (details)
  25. removed path to pom for sonarqube analysis (details)
  26. fixed broken links in client documentation (details)
  27. fixed broken links again (details)
  28. Implement and test HttpPublisher actor. (details)
  29. Fix javadoc. (details)
  30. Add HttpPushClientActor. (details)
  31. Improve dev configs to allow overrides via environment variables (details)
  32. Add tests to HttpPushClientActorTest; small fixes. (details)
  33. make initialization of client actors more robust (details)
  34. HttpPushFactory: Check failure-restart behavior. (details)
  35. Include only mapped headers in HTTP-push requests; fix validation and (details)
  36. Test TLS handshake and request-response for HTTP-push; reduce test log (details)
  37. HttpPublisher: Escalate unrecoverable errors to trigger restart with (details)
  38. review: * consolidated generics (to be always of same letter, to extend (details)
  39. added CQs of updated dependencies to cqs.md (details)
  40. enabled dropping empty suffixed collections in things + policies (details)
  41. remove artificial delay (details)
  42. Merge ditto-service-extension.conf during build (details)
  43. Add normalized message mapper. (details)
  44. Configure HTTP verb in target address; remove test request; fix logging (details)
  45. Add "fields" option to NormalizedMessageMapper; remove outdated (details)
  46. extract 'exp' claim from JWT. close WS session when JWT expired. (details)
  47. Use mapMaterializedValue trick to abort in-flight request in test. (details)
  48. HttpPushFactoryTest: Fix a timing error. (details)
  49. NormalizedMessageMapper: reduce redundant info, test full thing payload (details)
  50. introduce new 'mappings' field to connection model and allow sources and (details)
  51. allow logging of raw http headers if header 'ditto-trace-headers' is (details)
  52. allow logging of raw http headers if header 'ditto-trace-headers' is (details)
  53. Fixed Javadoc comments and added parentheses to body of equals method. (details)
  54. Remove dependency of services-utils-persistence on (details)
  55. Remove unnecessary overriden method and some unused imports (details)
  56. HttpPublisher: Handle content-type header especially. (details)
  57. HttpPushFactory: set flow input buffer = parallelism. (details)
  58. https://github.com/eclipse/ditto/issues/494: elevated security context (details)
  59. Make insecure devops configurable in helm (details)
  60. Implement "Connection event" and mappingOption to (details)
  61. Implement mapping context options evaluation. Add validation for mapping (details)
  62. #17 added an authentication provider for client credentials oauth, (details)
  63. fixed that UnmappedOutboundSignal did not serialize/deserialize (details)
  64. fixed connectivity metrics gauges * they were not resetted when the (details)
  65. fix review findings (details)
  66. Fix #499. (details)
  67. review: * added missing javadocs * allow to use query param for (details)
  68. review: minor formatting (details)
  69. fixed unit tests after merge; renamed HttpPublisherActor (details)
  70. - allow multiple mappings for sources and targets that each produce (details)
  71. fix license headers (details)
  72. reduced snapshot logging from info to debug (details)
  73. use new adopter mechanism provided by Eclipse IoT to show "who's using (details)
  74. fix bug which caused caches to not be invalidated because the (details)
  75. add JwtValidator, JwtToken and ResetSessionTimer; extend WS protocol to (details)
  76. disabled URI path validation as there could be placeholders in it (details)
  77. fixed propoprtions of height of adopter logos on website (details)
  78. Do not allow multiple slashes in JSON pointers - throw an exception (details)
  79. Do not longer merge double slashes in the REST endpoints (details)
  80. fix test of ThingsRoute which does not longer get an (details)
  81. added documentation about new ConnectionType "http-push" (details)
  82. prevent the state timeout canceling when switching to UNKNOWN state * (details)
  83. Set default Http-push queue size to 100. (details)
  84. Refactor blocking wait into future. (details)
  85. Add final keyword and improve javadoc (details)
  86. fixed AbstractJsonWebTokenTest; add method to JsonWebToken to check (details)
  87. configure resource limits for memory for helm templates, fixes #502 (details)
  88. Add docs about the openid connect feature (details)
  89. updated publishing date of blogpost about HTTP connections (details)
  90. updated context-overview.png image by adding HTTP based connections (details)
  91. #17 moved JsonWebToken to model (details)
  92. #17 fixed compile errors (details)
  93. Test multiple client actors; disregard ack from remotely deployed client (details)
  94. PubSubFactoryTest.startSeveralTimes: Reduce probability of failure (details)
  95. Fix typo (details)
  96. removed dead "else" branch (details)
  97. Http-push: support basic auth. (details)
  98. change MessageMapper API to support multiple messages as result (details)
  99. Fix sonar findings. (details)
  100. Fix random reordering by JsonFieldSelector. (details)
  101. fix unit tests (details)
  102. Enhance docs of docker deployment (fixes #443) (details)
  103. fixed bug that etag for ModifyPolicyEntryStrategy and (details)
  104. fixed review findings on Ditto documentation (details)
  105. configured user-agent as "eclipse-ditto/<version>" for outgoing HTTP (details)
  106. ImmutableJsonObjectTest: test order of parenthetical selectors. (details)
  107. instantiate JwtAuthorizationContextProvider in GatewayRootActor; extract (details)
  108. add some more mapping tests (details)
  109. set mapper id from connection config (details)
  110. #17 [WIP] implemented token refresh (details)
  111. add mapper used to process inbound messages to internal headers and use (details)
  112. add methods to get and set mapper value from ditto headers and use them (details)
  113. Extract HttpProxyConfig from Gateway and reuse it for Http-push (details)
  114. Stabilize MqttClientActorTest. (details)
  115. send an acknowledge when a new JWT token was received over WS; handle (details)
  116. introduce types PayloadMappingDefinition and PayloadMapping in (details)
  117. Add stream component LimitRateByRejection and prepend it to websockets. (details)
  118. added validation of MappingContexts in AbstractProtocolValidator and (details)
  119. fix test (details)
  120. add javadoc, fix handling of null PayloadMapping in ExternalMessage (details)
  121. fix javadoc errors (details)
  122. made width of adopter logos relative in percent (details)
  123. review ConnectionStatusMessageMapper (details)
  124. implement reconnect back-off mechanism for targets in amqp connections (details)
  125. fix missing config value on amqp10.backoff.timeout for test and use (details)
  126. review: added using HttpProxyConf to HttpPushClientActor * added a (details)
  127. Load websocket config dynamically on each upgrade-to-websocket request. (details)
  128. fixed that clientTransport is only created when http proxy is enabled (details)
  129. Improve formatting and connection error log on JSON errors. (details)
  130. re-added explicit type <T> (details)
  131. added logging for request URI to connection logs (details)
  132. Move websocket rate limiter after signal construction. (details)
  133. WebsocketRoute: rearrange incoming stream. (details)
  134. Add counter for dropped WS messages. (details)
  135. Modernize RootRoute; make CustomHeadersHandler asynchronous. (details)
  136. added hostname blacklisting for HTTP endpoints which should not be (details)
  137. #17 removed ack for jwt via websocket (details)
  138. Add throttle stage to websocket to prevent rejections. (details)
  139. Rename Ditto header "subject" to "ditto-subject" to avoid collision with (details)
  140. removed configuring the max-parallelism - just check for valid number (details)
  141. replace loading of MessageMappers via its fully qualified class name by (details)
  142. Enhance HTTP-push blacklists by IP comparison and category test. (details)
  143. #17 moved instantiation of classes related to jwt authentication into (details)
  144. Remove javadoc on escaping of slashes in JsonPointers (details)
  145. #17 minor changes (details)
  146. review: * fixed copy&paste error in javadocs * extracted StreamingConfig (details)
  147. fix test errors after review changes (details)
  148. fix that streamingConfig instead of websocketConfig was returned after (details)
  149. added missing @Nullable annotations in TooManyRequestsException (details)
  150. added slides for status presentation @ EclipseCon 2019 (details)
  151. Apply hostname blacklisting to all connection types. (details)
  152. adjusted blogpost date (details)
  153. fix loading of fallback mappers + add tests (details)
  154. prefixed all internal MessageHeaders with "ditto-message-" * removed (details)
  155. Fix flickering unit tests. (details)
  156. Silence "unnecessary stubbing" in AmqpClientActorTest. (details)
  157. stabilize AmqpClientActorTest by using another style for Mockito mocks * (details)
  158. BaseClientActor: Remove reliance on state timeout. (details)
  159. Update documentation on versioning of the javascript client releases (details)
  160. updated stats (details)
  161. Special treatment of ttd = 0 header (details)
  162. review: added javadocs to BaseClientData + simplified BaseClientData (details)
  163. Fix unit test. Add unit test for context validating (details)
  164. Remove "status" from outgoing headers - it was blocked by incompatible (details)
  165. Prevent client actors from opening the connection when testing. (details)
  166. Suppress automatic connect in client actor unit tests. (details)
  167. Fix a NullPointerException in AmqpClientActorTest. (details)
  168. fixes #467: document eventual consistency in things-search (details)
  169. fixes #460: document that topics as well as queues might be configured (details)
  170. improvements on the configuration section of operating Ditto (details)
  171. Issue 526: don't find things that are marked to be deleted by mongodb (details)
  172. Remove remnant of an unreleased module. (details)
  173. Make field "message" optional in serialization of DittoRuntimeException. (details)
  174. Remove batch command functionality. (details)
  175. Issue 526: add tests to verify that deleted things aren't found by the (details)
  176. Issue 516: Remember in AmqpPublisherActor if currently in backOff mode (details)
  177. adapt NormalizedMessageMapper to changes (details)
  178. fix mapping config validation (details)
  179. fixed compile errors after merge (details)
  180. fixed StreamingActor (details)
  181. fixed more compile errors (details)
  182. disable validation of mappings in model, change unit of creation-time to (details)
  183. fix connection test (details)
  184. ignore test temp. (details)
  185. skip tests temp. (details)
  186. revert temp. changes (details)
  187. capitalize first character of mapper aliases (details)
  188. #17 adapted documentation to api changes (details)
  189. fix that for each things HTTP call the sseRoute handling caused a too (details)
  190. add unit test to verify backoff behavior for amqp publisher creation (details)
  191. fixed formatting (details)
  192. Implement message payload mapping number validation. Add unit test (details)
  193. Add comments for payload mapping number validation. Change corresponding (details)
  194. Ignore ProducerClosedReports while AmqpPublisherActor is already in (details)
  195. set payload mapping in mqqt consumer actors (details)
  196. #17 renamed jwt claim constants (details)
  197. do not overwrite existing mappings in migration (details)
  198. review: * removed ConnectionBuilder.mappingDefinition method as it was (details)
  199. Implement limitation of messages per mapping (details)
  200. review: * adjusted naming of boolean of PayloadMapper annotation * some (details)
  201. add own documentation page on namespaces and names of things (details)
  202. update OpenAPI documentation for API 1 with link to the ID documentation (details)
  203. fix syntax errors in OpenAPI for Ditto API v1 (details)
  204. update OpenAPI documentation for API 2 with link to the ID documentation (details)
  205. fix syntax errors in OpenAPI for Ditto API v2 (details)
  206. #533 adapted JwtSubjectIssuersConfig to support both https and non-https (details)
  207. Update description for invalid thingIDs and policyIDs and add a link to (details)
  208. validate configured mapper references (details)
  209. review: * made placeholders also usable for configured featureId * (details)
  210. update JSON schema documentation of the thing ID and policy ID (details)
  211. fix compile error (details)
  212. document that the issuer config should not contain the protocol part of (details)
  213. adjusted config to changes of #535 (details)
  214. Add unit test for limitation of messages per mappings. (details)
  215. made it possible to configure a "content-type-blacklist" * for all (details)
  216. fixed merge conflicts; (details)
  217. added one more unit test for overwriting the content-type-blacklist (details)
  218. fixed log statement - was no "failure" (details)
  219. review: enhanced thrown ConnectionConfigurationInvalidException with a (details)
  220. document changes to payload mapping (details)
  221. try to stabilize AmqpClientActorTest (details)
  222. ignoring two test cases; will be fixed on another branch; (details)
  223. stabilize AmqpClientActorTest (details)
  224. stabilize AmqpPublisherActorTest (details)
  225. feature id can also be resolved from headers (details)
  226. Add mapper limits to config (details)
  227. fix bug that showed up when deleting a complex attribute with a path (details)
  228. fixed that "status" json object was missing in (details)
  229. review: * restructured connectivity-mapping.md in order to first list (details)
  230. Use mapper limits from connectivity config (details)
  231. prefix internal mapper header (ditto-mapper), move injection of header (details)
  232. fix mapping config tests (details)
  233. changed mapper of of "migrated" to "javascript" as this is currently the (details)
  234. fix long-running ditto build (details)
  235. - review of mapper limits, moved initialization of limits to (details)
  236. review: renamed newly introduced DittHeader "mapper" to (details)
  237. added release notes and blogpost about 1.0.0-M2 (details)
  238. removed "to be removed CQs" from cqs.md list (details)
  239. reset some log levels, dev config settings (details)
Commit c4f8ec51f16c555650fabdaf6eaac587fb548261 by juergen.fickel
Use varargs for constructor parameter to make super constructor calls
smoother.
Signed-off-by: Juergen Fickel <juergen.fickel@bosch-si.com>
The file was modifiedservices/thingsearch/starter/src/test/java/org/eclipse/ditto/services/thingsearch/starter/ThingSearchServiceGlobalErrorRegistryTest.java (diff)
The file was modifiedservices/connectivity/starter/src/test/java/org/eclipse/ditto/services/connectivity/ConnectivityServiceGlobalErrorRegistryTest.java (diff)
The file was modifiedservices/concierge/starter/src/test/java/org/eclipse/ditto/services/concierge/starter/ConciergeServiceGlobalErrorRegistryTest.java (diff)
The file was modifiedservices/policies/starter/src/test/java/org/eclipse/ditto/services/policies/starter/PoliciesServiceGlobalErrorRegistryTest.java (diff)
The file was modifiedservices/things/starter/src/test/java/org/eclipse/ditto/services/things/starter/ThingsServiceGlobalErrorRegistryTest.java (diff)
The file was modifiedservices/gateway/starter/src/test/java/org/eclipse/ditto/services/gateway/starter/GatewayServiceGlobalErrorRegistryTest.java (diff)
The file was modifiedservices/utils/test/src/test/java/org/eclipse/ditto/services/utils/test/GlobalErrorRegistryTestCases.java (diff)
Commit a9d00eb380953a4f00c7e09e2adf9e9379b6a5bc by juergen.fickel
Added convenience method for getting instance with warn level.
Signed-off-by: Juergen Fickel <juergen.fickel@bosch-si.com>
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/StatusDetailMessage.java (diff)
Commit 32d1e9f87e6d73043e76e0ad946534e9b23d10a1 by yufei.cai
Consolidate persistence actor supervision in
services/utils/persistent-actors.
- Reconfigured default backoff behavior to have longer maximum
backoff duration and more variance.
- Added "corrupted" behavior for failed initialization.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/utils/pom.xml (diff)
The file was modifiedservices/connectivity/messaging/pom.xml (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicySupervisorActor.java (diff)
The file was modifiedbom/pom.xml (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff)
The file was modifiedservices/base/src/main/java/org/eclipse/ditto/services/base/config/supervision/DefaultExponentialBackOffConfig.java (diff)
The file was removedservices/utils/cleanup/pom.xml
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was modifiedservices/policies/starter/src/main/resources/policies.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionSupervisorActor.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractPersistenceSupervisor.java
The file was removedservices/utils/cleanup/src/test/resources/logback-test.xml
The file was modifiedservices/policies/persistence/pom.xml (diff)
The file was modifiedservices/things/persistence/pom.xml (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractPersistentActorWithTimersAndCleanup.java
The file was modifiedservices/connectivity/starter/src/main/java/org/eclipse/ditto/services/connectivity/actors/ConnectivityRootActor.java (diff)
The file was modifiedservices/base/src/main/java/org/eclipse/ditto/services/base/config/supervision/ExponentialBackOffConfig.java (diff)
The file was removedservices/utils/cleanup/src/test/java/org/eclipse/ditto/services/utils/cleanup/MockJournalPlugin.java
The file was addedservices/utils/persistent-actors/pom.xml
The file was removedservices/utils/cleanup/src/test/resources/test.conf
The file was addedservices/utils/persistent-actors/src/test/resources/logback-test.xml
The file was addedservices/utils/persistent-actors/src/test/resources/test.conf
The file was modifiedservices/connectivity/starter/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceOperationsActorIT.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingSupervisorActor.java (diff)
The file was modifiedservices/base/src/main/java/org/eclipse/ditto/services/base/actors/ShutdownBehaviour.java (diff)
The file was removedservices/utils/cleanup/src/test/java/org/eclipse/ditto/services/utils/cleanup/AbstractPersistentActorWithTimersAndCleanupTest.java
The file was removedservices/utils/cleanup/src/test/java/org/eclipse/ditto/services/utils/cleanup/MockSnapshotStorePlugin.java
The file was addedservices/utils/persistent-actors/src/test/java/org/eclipse/ditto/services/utils/persistentactors/MockSnapshotStorePlugin.java
The file was removedservices/utils/cleanup/src/main/java/org/eclipse/ditto/services/utils/cleanup/AbstractPersistentActorWithTimersAndCleanup.java
The file was addedservices/utils/persistent-actors/src/test/java/org/eclipse/ditto/services/utils/persistentactors/AbstractPersistentActorWithTimersAndCleanupTest.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionActorTest.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/package-info.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/TestConstants.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActor.java (diff)
The file was modifiedservices/things/starter/src/main/resources/things.conf (diff)
The file was addedservices/utils/persistent-actors/src/test/java/org/eclipse/ditto/services/utils/persistentactors/MockJournalPlugin.java
The file was modifiedservices/base/src/test/resources/exponentialBackOff-test.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionActor.java (diff)
The file was removedservices/utils/cleanup/src/main/java/org/eclipse/ditto/services/utils/cleanup/package-info.java
Commit d1ab0bd04ddb739a53ce41c02d2a6d238c63576c by yufei.cai
Extract results of persistent actor command strategies into a utility.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was addedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/package-info.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAttributesStrategy.java (diff)
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/CommandReceiveStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ETagEntityProvider.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAclEntryStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAclStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturePropertyStrategy.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/results/QueryResult.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyPolicyIdStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAttributesStrategy.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/results/ResultFactory.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturePropertiesStrategy.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/results/Result.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeatureStrategy.java (diff)
The file was modifiedservices/utils/persistent-actors/pom.xml (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ResultFactoryTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeatureDefinitionStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/CommandStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAclEntryStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAttributeStrategy.java (diff)
The file was modifiedbom/pom.xml (diff)
The file was addedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/AbstractReceiveStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturePropertyStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/CreateThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ThingConflictStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/AbstractCommandStrategyTest.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/results/EmptyResult.java
The file was removedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/CommandReceiveStrategyTest.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturePropertyStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAclEntryStrategy.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/results/ResultVisitor.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAttributesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAttributeStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturePropertiesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/AbstractConditionalHeadersCheckingCommandStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeatureDefinitionStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/AbstractCommandStrategy.java (diff)
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ResultFactory.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/SudoRetrieveThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAttributeStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrievePolicyIdStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAclStrategy.java (diff)
The file was addedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ThingReceiveStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/strategies/AbstractReceiveStrategy.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/results/package-info.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturePropertiesStrategy.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/results/MutationResult.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeatureStrategy.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/results/ErrorResult.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DefaultContext.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeatureStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActorCleanupTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeatureDefinitionStrategy.java (diff)
Commit d466857ddf063740af46b6bbfc21ff488b9db2b9 by yufei.cai
Extract persistent actor command strategies into a utility.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturePropertyStrategyTest.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/CommandStrategy.java
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAttributeStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAclEntryStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAttributesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeatureStrategyTest.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/AbstractReceiveStrategy.java
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveThingStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAttributesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturePropertyStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAttributesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAclStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAttributeStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeatureDefinitionStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAclStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturePropertiesStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturePropertyStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturePropertyStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeatureStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturePropertyStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturePropertyStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturesStrategyTest.java (diff)
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/AbstractCommandStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrievePolicyIdStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeatureStrategyTest.java (diff)
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/AbstractReceiveStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/SudoRetrieveThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAttributesStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/CreateThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturePropertiesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ThingConflictStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAttributeStrategyTest.java (diff)
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/CommandStrategy.java
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturePropertiesStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAttributeStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturePropertiesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/AbstractCommandStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeatureDefinitionStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturePropertiesStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturesStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeatureDefinitionStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeatureDefinitionStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAttributeStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrievePolicyIdStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturePropertiesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeatureStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyPolicyIdStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeatureStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturesStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeatureDefinitionStrategyTest.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/package-info.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ExceptionFactory.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DefaultContext.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/SudoRetrieveThingStrategyTest.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/AbstractCommandStrategy.java
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAttributesStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ThingsConditionalHeadersValidatorProvider.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/AbstractConditionalHeadersCheckingCommandStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAclStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyPolicyIdStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAttributeStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAclEntryStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteThingStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAclStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAclEntryStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAclEntryStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeatureStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ThingReceiveStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAclEntryStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAclEntryStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAttributesStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ETagEntityProvider.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeatureDefinitionStrategyTest.java (diff)
Commit aa46637bab804c28f70aa1fb029ebbdceb9c42e0 by yufei.cai
Extract persistent actor event strategies into a utility.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/EventHandleStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/events/AbstractHandleStrategy.java
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/events/package-info.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/ThingCreatedStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/AbstractEventStrategy.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/events/EventStrategy.java
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/EventStrategy.java
Commit 59f8e84653ae1acd5f9d5e24eeaab8fd3ea95394 by yufei.cai
Extract common behavior of persistent actor into an abstract class.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeatureStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAttributeStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAttributeStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/CreateThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/AbstractConditionalHeadersCheckingCommandStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAclEntryStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/SudoRetrieveThingStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturesStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAclStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrievePolicyIdStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturePropertyStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeatureStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAttributesStrategy.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/AbstractCommandStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAclStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturePropertiesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturePropertyStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeatureDefinitionStrategy.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/DefaultContext.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeatureStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAttributeStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyPolicyIdStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAclEntryStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/testhelper/Assertions.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeatureDefinitionStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeatureDefinitionStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAclEntryStrategyTest.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractShardedPersistenceActor.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveThingStrategy.java (diff)
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/strategies/DelegateStrategy.java
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAclStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAttributesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeatureStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAttributeStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAclEntryStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteThingStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyPolicyIdStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturePropertiesStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturePropertyStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ThingConflictStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAttributesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ThingReceiveStrategy.java (diff)
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DefaultContext.java
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveThingStrategyTest.java (diff)
The file was removedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/DelegateStrategyTest.java
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/StrategyAwareReceiveBuilder.java
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/package-info.java (diff)
The file was removedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/StrategyAwareReceiveBuilderTest.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/SudoRetrieveThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturePropertiesStrategyTest.java (diff)
The file was modifiedservices/utils/persistent-actors/pom.xml (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAttributesStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturePropertyStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAttributesStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeatureDefinitionStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturePropertyStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturesStrategyTest.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/CommandStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAclEntryStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/AbstractCommandStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturePropertyStrategyTest.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/AbstractReceiveStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeatureStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeatureDefinitionStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturePropertiesStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturesStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeatureStrategyTest.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractPersistentActorWithTimersAndCleanup.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAttributeStrategyTest.java (diff)
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/strategies/AbstractReceiveStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturePropertiesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAclStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturePropertiesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrievePolicyIdStrategy.java (diff)
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/strategies/ReceiveStrategy.java
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAttributesStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAttributeStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeatureDefinitionStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAclEntryStrategyTest.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/events/package-info.java (diff)
Commit d7b79378295770f4b73f51ebc721ae8140b63bd2 by yufei.cai
Refactor policy persistence actor using
services/utils/persistence-actors.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturePropertyStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/SudoRetrieveThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAclStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAttributeStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturePropertiesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAttributeStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrievePolicyIdStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/CreateThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAttributesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeatureDefinitionStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAclEntryStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAttributesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAclEntryStrategy.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/etags/AbstractConditionHeaderCheckingCommandStrategy.java
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/AbstractConditionalHeadersCheckingCommandStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveThingStrategy.java (diff)
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ETagEntityProvider.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturePropertyStrategy.java (diff)
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/etags/package-info.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturePropertiesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturesStrategy.java (diff)
The file was addedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/AbstractThingCommandStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturePropertyStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeatureDefinitionStrategy.java (diff)
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyEventStrategies.java
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractShardedPersistenceActor.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturePropertiesStrategy.java (diff)
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyCommandStrategies.java
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/etags/ETagEntityProvider.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeatureStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyPolicyIdStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeatureStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActor.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAclStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActorTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAclEntryStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeatureDefinitionStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAttributesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeatureStrategy.java (diff)
The file was modifiedservices/utils/persistent-actors/pom.xml (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAttributeStrategy.java (diff)
Commit 7b6bdf6ca57fbb6310e5bbe54bf1a950fa32f619 by yufei.cai
[wip] Refactor ConnectionActor to compilable state.
It is not functional---StagedCommand is not interpreted.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultConnectionConfig.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultSnapshotConfig.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionDeletedStrategies.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionCreatedStrategies.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionEventStrategies.java
The file was modifiedsignals/commands/connectivity/pom.xml (diff)
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultConnectionConfigTest.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/stages/StagedCommand.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/stages/ConnectionAction.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff)
The file was modifiedsignals/commands/connectivity/src/test/java/org/eclipse/ditto/signals/commands/connectivity/modify/ModifyConnectionResponseTest.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/stages/package-info.java
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/AbstractReceiveStrategy.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/AbstractCommandStrategyTest.java (diff)
The file was modifiedsignals/commands/connectivity/src/main/java/org/eclipse/ditto/signals/commands/connectivity/modify/ModifyConnectionResponse.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractShardedPersistenceActor.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/SnapshotConfig.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/ConnectionConfig.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ResultFactoryTest.java (diff)
The file was modifiedsignals/commands/connectivity/src/test/java/org/eclipse/ditto/signals/commands/connectivity/examplejson/JsonExamplesProducer.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionActorTest.java (diff)
Commit 078c4372fdd414745fb9d488e80c98c93df034a8 by yufei.cai
Make strategy context dynamic.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionCreatedStrategies.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActor.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/stages/ConnectionState.java
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractShardedPersistenceActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionDeletedStrategies.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionActor.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff)
Commit d05b0b4c1c3d4ee5979a40b080c094c8bf5bbe1c by yufei.cai
ConnectionActor: validate test and modify commands, check for activity.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was modifiedservices/utils/persistence/src/test/resources/activity-check-test.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionCreatedStrategies.java (diff)
The file was modifiedservices/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/config/DefaultActivityCheckConfigTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionDeletedStrategies.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractShardedPersistenceActor.java (diff)
Commit 561192f4c32f65076bdf8689694c26fac27d12cc by yufei.cai
ConnectionActor: Handle actions and forward signals.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionActorTest.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/AbstractReceiveStrategy.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/stages/ConnectionAction.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionCreatedStrategies.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/stages/StagedCommand.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractShardedPersistenceActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionDeletedStrategies.java (diff)
Commit 16841e2e9eb578788f40f806f5adce21fc6438a7 by yufei.cai
Fix ModifyConnectionResponseTest.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedsignals/commands/connectivity/src/test/java/org/eclipse/ditto/signals/commands/connectivity/modify/ModifyConnectionResponseTest.java (diff)
Commit 8d1f9284c83d2aae417270a3c5b7b8c76112df65 by yufei.cai
Fix tests, cleanup code.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionCreatedStrategies.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionDeletedStrategies.java (diff)
The file was modifiedservices/utils/test/src/test/java/org/eclipse/ditto/services/utils/test/GlobalCommandRegistryTestCases.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionActor.java (diff)
The file was modifiedservices/connectivity/starter/src/test/java/org/eclipse/ditto/services/connectivity/ConnectivityServiceGlobalCommandRegistryTest.java (diff)
Commit 85ae5ea4fac798825ef0a0e5080e8f39e6f49c73 by yufei.cai
Rearrange code, fix TODOs, add javadoc.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/write/streaming/EnforcementFlow.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/stages/ConnectionState.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionEventStrategies.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionCreatedStrategies.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/stages/StagedCommand.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionActor.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractShardedPersistenceActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionDeletedStrategies.java (diff)
Commit b4047df73c3813a7e9250de9c4d3cacd84a7b010 by yufei.cai
Restore accidentally removed overloaded method.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/starter/src/main/java/org/eclipse/ditto/services/connectivity/actors/ConnectivityRootActor.java (diff)
Commit 18f276dc62adcaee470aa925d849d7e8e5c44c69 by yufei.cai
Fix etag handling of CreatePolicy and CreateThing
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyCommandStrategies.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/CreateThingStrategy.java (diff)
Commit 7de929a2a5bfaf38cd4d0c7dce0383b448b01bb4 by yufei.cai
ETag handling: split entity extractor between previous and next state.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAclStrategy.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/etags/AbstractConditionHeaderCheckingCommandStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAttributeStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAttributesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeatureStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturePropertyStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyCommandStrategies.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturePropertiesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturePropertyStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAclEntryStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeatureStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAclEntryStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeatureDefinitionStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeatureStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAttributeStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAttributesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeatureDefinitionStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/SudoRetrieveThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAttributeStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrievePolicyIdStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAclEntryStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyPolicyIdStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeatureDefinitionStrategy.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/etags/ETagEntityProvider.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturePropertyStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAttributesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/CreateThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturePropertiesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturePropertiesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAclStrategy.java (diff)
Commit 7bd9719de5ebd629cd367b2afd2857aa271d40d2 by yufei.cai
Add connection type http-push and its config, validator and publisher.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushValidator.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultHttpPushConfig.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisher.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionActor.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectionType.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaValidatorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQValidator.java (diff)
The file was modifiedmodel/connectivity/pom.xml (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactory.java
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/DittoConnectivityCommandValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/resources/connection-test.conf (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/MqttValidatorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/AbstractProtocolValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/MqttValidator.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublishTarget.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultConnectionConfig.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQValidatorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActor.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/package-info.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultConnectionConfigTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/ConnectionConfig.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/HttpPushConfig.java
The file was modifiedbom/pom.xml (diff)
Commit 4ef2940d80698673fc2e3598ca2dc65d9f8bc14a by Yannic Klem
remove double semicolon
Signed-off-by: Klem Yannic (INST/ECS1) <yannic.klem@bosch-si.com>
The file was modifiedjson/src/test/java/org/eclipse/ditto/json/JsonValueParserTest.java (diff)
Commit 4f61f1506de2b130b8dcb70c18254dbeed7650fb by Johannes Kraeher
added release notes for milestone 1.0.0-M1a
Signed-off-by: krj1imb <johannes.schneider@bosch-si.com>
The file was modifieddocumentation/src/main/resources/_posts/2018-05-02-connecting-ditto-hono.md (diff)
The file was addeddocumentation/src/main/resources/_posts/2019-09-17-milestone-announcement-100-M1a.md
The file was modifieddocumentation/src/main/resources/_data/sidebars/ditto_sidebar.yml (diff)
The file was addeddocumentation/src/main/resources/pages/ditto/release_notes_100M1a.md
Commit 9b13ddc86087c4a825a7158fa80e1eb50979260a by Johannes Kraeher
reverted unintended change to old blog post
Signed-off-by: krj1imb <johannes.schneider@bosch-si.com>
The file was modifieddocumentation/src/main/resources/_posts/2018-05-02-connecting-ditto-hono.md (diff)
Commit 0905d717b560e5299773ae7e0e83967e8d149b67 by vadim.guenther
Implement basic functionalities to ConnectionStatusMapper
Signed-off-by: Vadim Guenther <vadim.guenther@bosch-si.com>
The file was modifiedservices/connectivity/mapping/pom.xml (diff)
The file was addedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/custom/ConnectionStatusMessageMapper.java
Commit 7c1bbbc6d657eb24a184e9a75e74ad458ac0499a by Johannes Kraeher
added sonarqube analysis
Signed-off-by: krj1imb <johannes.schneider@bosch-si.com>
The file was modifiedJenkinsfile (diff)
Commit d346526dec4ce295ada4eb465cde997447ef57d5 by Johannes Kraeher
removed path to pom for sonarqube analysis
Signed-off-by: krj1imb <johannes.schneider@bosch-si.com>
The file was modifiedJenkinsfile (diff)
Commit 68b2c0e9e51e41c74f7fd880b8121392e0066590 by Johannes Kraeher
fixed broken links in client documentation
Signed-off-by: krj1imb <johannes.schneider@bosch-si.com>
The file was modifieddocumentation/src/main/resources/pages/ditto/client-sdk-java.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/client-sdk-javascript.md (diff)
Commit 66943165ce272c58c727a98850038e39b32ccdd9 by noreply
fixed broken links again
The file was modifieddocumentation/src/main/resources/pages/ditto/client-sdk-javascript.md (diff)
Commit c97b365cc536a8b7cd15f9806ba462120e6ad499 by yufei.cai
Implement and test HttpPublisher actor.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherActorTest.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushValidator.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/DefaultHttpPushFactory.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisher.java (diff)
Commit a967c888b165d1a03e7272c8992d71ad0be1ba02 by yufei.cai
Fix javadoc.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/ConnectionConfig.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ssl/SSLContextCreator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/AbstractProtocolValidator.java (diff)
Commit 8b2387358122eac0dde56872221dc478ed31d8ef by yufei.cai
Add HttpPushClientActor.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactory.java (diff)
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActorTest.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisher.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActorTest.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActor.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/TestConstants.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/DefaultHttpPushFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/DefaultClientActorPropsFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
Commit 24b75ec2f97d9605b6a518f813abee9ca6ac38a5 by Yannic Klem
Improve dev configs to allow overrides via environment variables
Signed-off-by: Klem Yannic (INST/ECS1) <yannic.klem@bosch-si.com>
The file was modifiedservices/things/starter/src/main/resources/things-dev.conf (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedPub.java (diff)
The file was modifiedservices/policies/starter/src/main/resources/policies-dev.conf (diff)
Commit 74d3355346e33eaa16684bba387e015150b25048 by yufei.cai
Add tests to HttpPushClientActorTest; small fixes.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActor.java (diff)
Commit 438f3910f4f269771534924942d6ffcd811e916b by dominik.guggemos
make initialization of client actors more robust
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActorTest.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InitializationState.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/alpakka/MqttPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/AbstractMqttClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientData.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt3ClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/alpakka/MqttPublisherActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/alpakka/MqttClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt3SubscriptionHandler.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQClientActor.java (diff)
Commit de76a5155bd97a69adf37dac460c901f9d4cd7ba by yufei.cai
HttpPushFactory: Check failure-restart behavior.
The default behavior is what we want. No change needed.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActorTest.java (diff)
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactoryTest.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/DefaultHttpPushFactory.java (diff)
Commit 48dc46c2933d8cb09c74e1d184e614403fb6084e by yufei.cai
Include only mapped headers in HTTP-push requests; fix validation and
tests.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was removedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherActorTest.java
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherTest.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisher.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidator.java (diff)
Commit 4eca31882f1ebf909c1ead6bf16e615f007c43d5 by yufei.cai
Test TLS handshake and request-response for HTTP-push; reduce test log
verbosity.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/resources/logback-test.xml (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactory.java (diff)
Commit 6e0ac2979a22ffbd19e768abcb429ab25725dc59 by yufei.cai
HttpPublisher: Escalate unrecoverable errors to trigger restart with
backoff.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisher.java (diff)
Commit 4f02d1b7c9e1ea827ff7c3a2543747f66b5d15dd by Thomas J??ckle
review: * consolidated generics (to be always of same letter, to extend
baseclasses where applicable) * added missing javadocs for generics *
renamed AbstractEventStrategy -> AbstractThingEventStrategy * extracted
inner classes of PolicyCommandStrategies, PolicyEventStrategies,
ConnectionCreatedStrategies, ConnectionDeletedStrategies,
ConnectionEventStrategies to upper levels * fixed some minor review
stuff on the way * updated dependencies of akka,
akka-mongo-persistence-plugin, used mongo driver versions,
akka-management, and some others
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was removedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionActorRecoveryTest.java
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/AbstractCommandStrategy.java (diff)
The file was modifiedlegal/3rd-party-dependencies/test.txt (diff)
The file was removedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policies/AbstractReceivePolicyCommandStrategy.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/TestConstants.java (diff)
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/PolicyConflictStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeatureDefinitionStrategy.java (diff)
The file was removedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/package-info.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/AttributesModifiedStrategy.java (diff)
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/events/ResourceModifiedStrategy.java
The file was modifiedlegal/templates/licenses-merges-file (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MockClientActor.java (diff)
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/EventHandleStrategy.java
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/results/ResultFactory.java (diff)
The file was removedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/AbstractReceiveStrategy.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/ReconnectActorTest.java (diff)
The file was removedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policies/SimpleForwardStrategy.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/events/ConnectionModifiedStrategy.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/ConnectionConflictStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/events/PolicyEntryModifiedStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/PolicyCommandStrategies.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/events/SubjectCreatedStrategy.java
The file was modifiedlegal/3rd-party-dependencies/compile.txt (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAclStrategy.java (diff)
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/SignalFilterWithFilterTest.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionEventStrategies.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/CreatePolicyStrategy.java
The file was modifiedservices/connectivity/starter/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceOperationsActorIT.java (diff)
The file was addedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/AbstractThingEventStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/FeaturePropertyCreatedStrategy.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/TestConnectionConflictStrategy.java
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/SignalFilterTest.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/ThingDeletedStrategy.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/AbstractSingleActionStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/PolicyPersistenceActor.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/StagedCommandStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/AclModifiedStrategy.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/etags/ETagEntityProvider.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionCreatedStrategies.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/OpenConnectionStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/events/ResourceCreatedStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifySubjectsStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifyResourceStrategy.java
The file was addedservices/policies/persistence/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/PolicyPersistenceActorSnapshottingTest.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/PolicySupervisorActor.java
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/events/AbstractEventStrategies.java
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractShardedPersistenceActor.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractPersistentActorWithTimersAndCleanup.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/EnableConnectionLogsStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/PolicyIdCreatedStrategy.java (diff)
The file was removedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActor.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/FeaturePropertiesDeletedStrategy.java (diff)
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifySubjectStrategy.java
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ThingReceiveStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/events/SubjectModifiedStrategy.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/package-info.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/ResetConnectionLogsStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/FeatureDefinitionModifiedStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/AttributeModifiedStrategy.java (diff)
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/RetrieveResourcesStrategy.java
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/results/Result.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/AclEntryDeletedStrategy.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/CreateConnectionStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/AbstractPolicyQueryCommandStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/RetrievePolicyStrategy.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/AbstractEphemeralStrategy.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/ResetConnectionMetricsStrategy.java
The file was removedservices/policies/persistence/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PoliciesConditionalHeadersValidatorTest.java
The file was removedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyEventStrategies.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/AttributesCreatedStrategy.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceStreamingActorCreator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/stages/ConnectionAction.java (diff)
The file was removedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceOperationsActor.java
The file was removedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/StrategyAwareReceiveBuilder.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/events/package-info.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/events/PolicyCreatedStrategy.java
The file was modifiedservices/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/MongoClientWrapperTest.java (diff)
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionPersistenceActorRecoveryTest.java
The file was modifiedservices/policies/starter/src/main/resources/policies.conf (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/CloseConnectionStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/events/PolicyEventStrategies.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/events/PolicyModifiedStrategy.java
The file was removedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policies/PoliciesPersistenceStreamingActorCreator.java
The file was removedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActorMailbox.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/FeaturesDeletedStrategy.java (diff)
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/package-info.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/SignalFilter.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/events/package-info.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionSupervisorActor.java
The file was addedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/AbstractCommandStrategies.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/RetrieveConnectionStatusStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/AttributesDeletedStrategy.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/results/EmptyResult.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/events/ConnectionEventStrategies.java
The file was modifiedlegal/3rd-party-dependencies/cqs.md (diff)
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/events/PolicyEntryCreatedStrategy.java
The file was addedservices/policies/persistence/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/PersistenceActorTestBase.java
The file was removedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/SignalFilterTest.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/AbstractPolicyCommandStrategy.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/SignalFilter.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/ModifyConnectionStrategy.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/events/ConnectionDeletedStrategy.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ReconnectActor.java (diff)
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/DeletePolicyEntryStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/FeatureDeletedStrategy.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/DeleteConnectionStrategy.java
The file was removedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/events/AbstractHandleStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/DeletePolicyStrategy.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/RetrieveConnectionLogsStrategy.java
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/events/EventStrategy.java (diff)
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifyResourcesStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/events/ResourceDeletedStrategy.java
The file was removedservices/policies/starter/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/policies/PolicyPersistenceOperationsActorIT.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/RetrievePolicyEntryStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/DeleteResourceStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/AbstractThingCommandStrategy.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/RetrieveConnectionStrategy.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/events/ConnectionClosedStrategy.java
The file was modifiedbom/pom.xml (diff)
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionPersistenceActorTest.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/FeaturePropertiesCreatedStrategy.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/events/ConnectionOpenedStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/RetrievePolicyEntriesStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/RetrieveResourceStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/PolicyPersistenceOperationsActor.java
The file was addedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ThingCommandStrategies.java
The file was modifiedlegal/NOTICE-THIRD-PARTY.md (diff)
The file was addedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/ThingEventStrategies.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/ErrorHandlingActorTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/FeatureModifiedStrategy.java (diff)
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/events/SubjectDeletedStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/RetrieveSubjectStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/SudoRetrievePolicyStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/events/ResourcesModifiedStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/events/SubjectsModifiedStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/package-info.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifyPolicyEntryStrategy.java
The file was removedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/AbstractReceiveStrategy.java
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/AbstractEventStrategy.java
The file was removedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/SignalFilterWithFilterTest.java
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/AbstractCommandStrategyTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/FeaturesCreatedStrategy.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/CommandStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/AttributeDeletedStrategy.java (diff)
The file was removedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/ReceiveStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/FeatureCreatedStrategy.java (diff)
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/events/PolicyDeletedStrategy.java
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/results/QueryResult.java (diff)
The file was removedservices/policies/persistence/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PersistenceActorTestBase.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/CreateThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/FeatureDefinitionDeletedStrategy.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/events/ConnectionCreatedStrategy.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/RetrieveConnectionMetricsStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/PoliciesPersistenceStreamingActorCreator.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/events/PolicyEntryDeletedStrategy.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/stages/package-info.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/AbstractActorWithLock.java (diff)
The file was removedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionActorTest.java
The file was removedservices/policies/persistence/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActorSnapshottingTest.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionActor.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifyPolicyStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/FeaturePropertiesModifiedStrategy.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceOperationsActor.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff)
The file was removedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicySupervisorActor.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/AttributeCreatedStrategy.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionSupervisorActor.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/LoggingExpiredStrategy.java
The file was addedservices/policies/persistence/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/PoliciesConditionalHeadersValidatorTest.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/DeleteSubjectStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/PolicyPersistenceActorMailbox.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifyPolicyEntriesStrategy.java
The file was removedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyCommandStrategies.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/FeaturePropertyDeletedStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/FeaturesModifiedStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/FeatureDefinitionCreatedStrategy.java (diff)
The file was removedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PoliciesConditionalHeadersValidatorProvider.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/stages/StagedCommand.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/results/ErrorResult.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/ConnectionCreatedStrategies.java
The file was addedservices/policies/starter/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/PolicyPersistenceOperationsActorIT.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/AclEntryModifiedStrategy.java (diff)
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/events/PolicyEntriesModifiedStrategy.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/PoliciesConditionalHeadersValidatorProvider.java
The file was removedservices/policies/persistence/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActorTest.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/PolicyIdModifiedStrategy.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/DefaultContext.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/ConnectionDeletedStrategies.java
The file was modifiedservices/connectivity/starter/src/main/java/org/eclipse/ditto/services/connectivity/actors/ConnectivityRootActor.java (diff)
The file was addedlegal/licenses/BSD-2-Clause.txt
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/AbstractConnectivityCommandStrategy.java
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractPersistenceSupervisor.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/etags/AbstractConditionHeaderCheckingCommandStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/AclEntryCreatedStrategy.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/results/ResultVisitor.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionDeletedStrategies.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/RetrieveSubjectsStrategy.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/FeaturePropertyModifiedStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/events/ThingModifiedStrategy.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/results/MutationResult.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/TestConnectionStrategy.java
The file was addedservices/policies/persistence/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/PolicyPersistenceActorTest.java
The file was modifiedservices/policies/starter/src/main/java/org/eclipse/ditto/services/policies/starter/PoliciesRootActor.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAttributesStrategy.java (diff)
Commit 889f1cd12900643f02d2f8b2716056409f1dce0f by Thomas J??ckle
added CQs of updated dependencies to cqs.md
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedlegal/3rd-party-dependencies/cqs.md (diff)
Commit 6a8b4e22f3420e57007d42111bf4981b98089d65 by Thomas J??ckle
enabled dropping empty suffixed collections in things + policies
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/things/starter/src/main/resources/things.conf (diff)
The file was modifiedservices/policies/starter/src/main/resources/policies.conf (diff)
Commit 0d33e536266333b0078f43eeedca558d1075b520 by dominik.guggemos
remove artificial delay
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/alpakka/MockMqttConnectionFactory.java (diff)
Commit 6ba606e1237b721efbdbb29c502c41cf9ac029de by Yannic Klem
Merge ditto-service-extension.conf during build
Signed-off-by: Klem Yannic (INST/ECS1) <yannic.klem@bosch-si.com>
The file was modifiedservices/things/starter/pom.xml (diff)
The file was modifiedservices/gateway/starter/pom.xml (diff)
The file was modifiedservices/concierge/starter/pom.xml (diff)
The file was modifiedservices/connectivity/starter/pom.xml (diff)
The file was modifiedservices/thingsearch/starter/pom.xml (diff)
The file was modifiedservices/policies/starter/pom.xml (diff)
Commit ac51390b33759fd6c006ebb2c3a8101d11118bb2 by yufei.cai
Add normalized message mapper.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was addedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/NormalizedMessageMapper.java
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/DittoMessageMapperTest.java (diff)
The file was addedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/NormalizedMessageMapperTest.java
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/Payload.java (diff)
Commit 0d77d79275a4f39e2d12fa705b045a3a997b9e32 by yufei.cai
Configure HTTP verb in target address; remove test request; fix logging
of queue offer failure in HttpPublisher.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/DefaultHttpPushFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublishTarget.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisher.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactoryTest.java (diff)
Commit 71da6ede720a9e1b85ab8818aef7230c4059e37b by yufei.cai
Add "fields" option to NormalizedMessageMapper; remove outdated
comments.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/NormalizedMessageMapperTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/NormalizedMessageMapper.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
Commit 5162b091f5a1e0a5b0516f6faed8060a6bb24ce7 by stefan.maute
extract 'exp' claim from JWT. close WS session when JWT expired.
Signed-off-by: Stefan Maute <stefan.maute@bosch-si.com>
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/RootRoute.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JsonWebToken.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/EventAndResponsePublisher.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingActor.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/CommandSubscriber.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebsocketRoute.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/AbstractJsonWebToken.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/sse/SseThingsRoute.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/Connect.java (diff)
The file was modifiedservices/gateway/streaming/pom.xml (diff)
The file was addedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayWebsocketSessionExpiredException.java
Commit 49921986f3d2af0c4ae9217e938c5b5277c0e55d by yufei.cai
Use mapMaterializedValue trick to abort in-flight request in test.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactoryTest.java (diff)
Commit 64f794dba5e613df9d5db741710f1ad6317cab6d by yufei.cai
HttpPushFactoryTest: Fix a timing error.
Cause: Akka HTTP can't terminate a stream with a blocking stage.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactoryTest.java (diff)
Commit a48bb3b085e9c9ae415fa7b20d0893e03fb5e557 by yufei.cai
NormalizedMessageMapper: reduce redundant info, test full thing payload
selector.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/NormalizedMessageMapper.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/NormalizedMessageMapperTest.java (diff)
Commit 55517e494b2b0f349b9f55b351e930bd46353d64 by dominik.guggemos
introduce new 'mappings' field to connection model and allow sources and
targets to reference one more more mappings by ID, legacy mapping
contexts are migrated to new model on the fly
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectionBuilder.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/Connection.java (diff)
The file was modifiedmodel/connectivity/src/test/java/org/eclipse/ditto/model/connectivity/ImmutableSourceTest.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/TargetBuilder.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/Source.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectivityModelFactory.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ImmutableSource.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ImmutableConnection.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/Target.java (diff)
The file was modifiedmodel/connectivity/src/test/java/org/eclipse/ditto/model/connectivity/ImmutableTargetTest.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ImmutableTarget.java (diff)
The file was modifiedmodel/connectivity/src/test/java/org/eclipse/ditto/model/connectivity/ImmutableConnectionTest.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/SourceBuilder.java (diff)
Commit 559be5c3873851381fb34fdd5182e9826ad11a6b by dominik.guggemos
allow logging of raw http headers if header 'ditto-trace-headers' is
provided
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/directives/RequestResultLoggingDirective.java (diff)
Commit ca80f3cf14965b39ae39c29593847d892a02855f by dominik.guggemos
allow logging of raw http headers if header 'ditto-trace-headers' is
provided
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/directives/RequestResultLoggingDirective.java (diff)
Commit c86c8f83b7661d4eac04bab810a5c855b3024732 by juergen.fickel
Fixed Javadoc comments and added parentheses to body of equals method.
Signed-off-by: Juergen Fickel <juergen.fickel@bosch-si.com>
The file was modifiedmodel/things/src/main/java/org/eclipse/ditto/model/things/ThingId.java (diff)
Commit d7977355c114f31eaa6619510ce2d615d7da376b by Yannic Klem
Remove dependency of services-utils-persistence on
services-models-things
* This eliminates a dependency of policies on things which didn't
make sense
Signed-off-by: Klem Yannic (INST/ECS1) <yannic.klem@bosch-si.com>
The file was modifiedmodel/policies/src/main/java/org/eclipse/ditto/model/policies/PolicyId.java (diff)
The file was modifiedmodel/things/src/main/java/org/eclipse/ditto/model/things/ImmutableThingFromCopyBuilder.java (diff)
The file was modifiedservices/policies/starter/src/test/java/org/eclipse/ditto/services/policies/starter/PoliciesServiceGlobalEventRegistryTest.java (diff)
The file was modifiedservices/policies/starter/src/test/java/org/eclipse/ditto/services/policies/starter/PoliciesServiceGlobalCommandResponseRegistryTest.java (diff)
The file was modifiedservices/utils/persistence/pom.xml (diff)
The file was modifiedservices/policies/starter/src/test/java/org/eclipse/ditto/services/policies/starter/PoliciesServiceGlobalCommandRegistryTest.java (diff)
The file was modifiedservices/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/NewEventForwarder.java (diff)
Commit 3837c7ed10bf572b6ef93e36a22834b11e501f80 by Yannic Klem
Remove unnecessary overriden method and some unused imports
Signed-off-by: Klem Yannic (INST/ECS1) <yannic.klem@bosch-si.com>
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/serializer/ThingMongoSnapshotAdapterTest.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/ThingMongoSnapshotAdapter.java (diff)
Commit 9a3956a858f465317061c13a75370ea180545e55 by yufei.cai
HttpPublisher: Handle content-type header especially.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisher.java (diff)
Commit 9956dca35edf3ff4517471b23acad9838e914f85 by yufei.cai
HttpPushFactory: set flow input buffer = parallelism.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/DefaultHttpPushFactory.java (diff)
Commit 6ac60e0a92264658670e6b8e07ef1e74abe785a6 by Bob Claerhout
https://github.com/eclipse/ditto/issues/494: elevated security context
for openshift + documentation change to install using helm
Signed-off-by: Bob Claerhout <bob.claerhout@aloxy.io>
The file was modifieddeployment/helm/README.md (diff)
The file was modifieddeployment/helm/eclipse-ditto/templates/nginx.yaml (diff)
The file was modifieddeployment/helm/eclipse-ditto/templates/swagger.yaml (diff)
The file was modifieddeployment/helm/eclipse-ditto/values.yaml (diff)
Commit b65a495cfc39df1dc535e468ee185307200f463e by Bob Claerhout
Make insecure devops configurable in helm
Signed-off-by: Bob Claerhout <bob.claerhout@aloxy.io>
The file was modifieddeployment/helm/eclipse-ditto/values.yaml (diff)
The file was modifieddeployment/helm/eclipse-ditto/templates/gateway.yaml (diff)
Commit 7334fe9f3ee4aa99032cfb334bc3242a289c9faf by vadim.guenther
Implement "Connection event" and mappingOption to
ConnectionStatusMapper. Implement unit test
Signed-off-by: Vadim Guenther <vadim.guenther@bosch-si.com>
The file was addedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/custom/ConnectionStatusMessageMapperTest.java
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/custom/ConnectionStatusMessageMapper.java (diff)
Commit 2327a1b5f7833e33ead3cb9934574f878fa9790d by vadim.guenther
Implement mapping context options evaluation. Add validation for mapping
context options
Signed-off-by: Vadim Guenther <vadim.guenther@bosch-si.com>
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/custom/ConnectionStatusMessageMapperTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/custom/ConnectionStatusMessageMapper.java (diff)
Commit 7b032cca3fb2093c416c3364a9a0e9d7d975e75a by Johannes Kraeher
#17 added an authentication provider for client credentials oauth,
changed how configuration is passed into a client at instantiation.
Signed-off-by: krj1imb <johannes.schneider@bosch-si.com>
The file was modifieddocumentation/src/main/resources/pages/ditto/client-sdk-java.md (diff)
Commit 6be36f84eb7e49019bd3d425c2e8d1720f9e8b2b by Thomas J??ckle
fixed that UnmappedOutboundSignal did not serialize/deserialize
DittoHeaders
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/OutboundSignal.java (diff)
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/UnmappedOutboundSignal.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectivityStatus.java (diff)
Commit ef71266aa79afab3fd9b4c64113c868c77a3e5a5 by Thomas J??ckle
fixed connectivity metrics gauges * they were not resetted when the
actor closed * they could be incremented for the same connection id and
type multiple times which makes no sense
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientData.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
Commit 7a0df147969170c04a1caf28a53eab807b82ccca by yufei.cai
Fix #499.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/RetrievePolicyStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeatureDefinitionStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifyResourcesStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/RetrieveSubjectStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAttributeStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyPolicyIdStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeatureStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAclEntryStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/RetrieveResourceStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeatureStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/CreateThingStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/AbstractPolicyQueryCommandStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/SudoRetrieveThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturePropertyStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/PolicyConflictStrategy.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeatureStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeatureDefinitionStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifyPolicyEntriesStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/DeleteResourceStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/CreatePolicyStrategy.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/etags/AbstractConditionHeaderCheckingCommandStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAttributesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturePropertyStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAttributesStrategy.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/etags/ETagEntityProvider.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAttributeStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAttributesStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifyResourceStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveThingStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/RetrievePolicyEntriesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAclEntryStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifySubjectStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturePropertiesStrategy.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractShardedPersistenceActor.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/DeletePolicyEntryStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/SudoRetrievePolicyStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAttributeStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyThingStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifySubjectsStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteAclEntryStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturePropertiesStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/DeletePolicyStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifyPolicyEntryStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/RetrievePolicyEntryStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeaturesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturesStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/RetrieveSubjectsStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveAclStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifyPolicyStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyAclStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/DeleteSubjectStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrievePolicyIdStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/RetrieveResourcesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyFeaturePropertyStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteThingStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/RetrieveFeaturePropertiesStrategy.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteFeatureDefinitionStrategy.java (diff)
Commit c25e135489321c693bde903f3c4ff34e7d6984cd by Thomas J??ckle
review: * added missing javadocs * allow to use query param for
HttpPublishTargets * in case of an HTTP error, not only add the status
to the user log, but also the body
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublishTarget.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultHttpPushConfig.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/ConnectionMonitor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/DefaultHttpPushFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisher.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/ConnectionLogger.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherTest.java (diff)
Commit ae97b0171a7cd0ae0b3266deb971ab7ba586b87a by Thomas J??ckle
review: minor formatting
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/NormalizedMessageMapper.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/NormalizedMessageMapperTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
Commit 5d0b6e817daf73cba1d6e77be56b72c6fb4c9c79 by Thomas J??ckle
fixed unit tests after merge; renamed HttpPublisherActor
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherActor.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactoryTest.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisher.java
The file was removedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherTest.java
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherActorTest.java
Commit 67fe89fd8f1692cb2e251f814d5d15ca3eda775b by dominik.guggemos
 - allow multiple mappings for sources and targets that each produce
independent messages  - allow MessageMapper to produce multiple messages
from a single input message (wip)
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMessageMapperRegistry.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/javascript/DefaultIncomingMappingTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMessageMapperFactory.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/DittoMessageMapper.java (diff)
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/ExternalMessage.java (diff)
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/UnmodifiableExternalMessageBuilder.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/MessageMapperRegistry.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/javascript/DefaultIncomingMapping.java (diff)
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/InboundExternalMessage.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/test/MockMapper.java (diff)
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/ExternalMessageBuilder.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/MessageMapperFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessor.java (diff)
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/UnmodifiableExternalMessage.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/WrappingMessageMapper.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/MessageMapper.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/custom/ConnectionStatusMessageMapper.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/javascript/DefaultOutgoingMapping.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingResultHandler.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActorTest.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MappingTimer.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionActor.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingResultHandler.java
The file was addedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/custom/package-info.java
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMessageMapperFactoryTest.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MappingResultHandler.java
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/javascript/ScriptedIncomingMapping.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/javascript/ScriptedOutgoingMapping.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/javascript/JavaScriptMessageMapperRhino.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActor.java (diff)
Commit d3ebf6557f84d87ea75ec861a6a50e74974d3f7a by dominik.guggemos
fix license headers
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/custom/ConnectionStatusMessageMapperTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/custom/ConnectionStatusMessageMapper.java (diff)
Commit de048a1c7f58927874762cfe8dff819468772dc0 by Thomas J??ckle
reduced snapshot logging from info to debug
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractShardedPersistenceActor.java (diff)
Commit ddfd5e20a1d7d8c46f3f44e8f4615564d8a5d30b by Thomas J??ckle
use new adopter mechanism provided by Eclipse IoT to show "who's using
Ditto" on the startpage as documented here:
https://github.com/eclipsefdn/iot.eclipse.org#javascript-plugin
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifieddocumentation/src/main/resources/_layouts/start.html (diff)
The file was modifieddocumentation/src/main/resources/index.html (diff)
The file was modifieddocumentation/src/main/resources/css/customstyles.css (diff)
Commit 7d4005902bc58e7499c367957504fbaf9e18702b by Florian Fendt
fix bug which caused caches to not be invalidated because the
deserialized entity ids could not be matched to the cached entity ids.
Now the entity id with resource type (which is used for the caches) is
always converted to a DefaultEntityId and thus allows comparing them
after deserialization.
Signed-off-by: Florian Fendt <Florian.Fendt@bosch-si.com>
The file was modifiedservices/utils/cache/src/main/java/org/eclipse/ditto/services/utils/cache/ImmutableEntityIdWithResourceType.java (diff)
The file was modifiedservices/utils/cache/src/test/java/org/eclipse/ditto/services/utils/cache/ImmutableEntityIdWithResourceTypeTest.java (diff)
Commit 73218b44edb5a0e50eeed292157333d39efbd136 by stefan.maute
add JwtValidator, JwtToken and ResetSessionTimer; extend WS protocol to
renew WS session with new JwtToken;
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/ProtocolMessages.java (diff)
The file was modifiedservices/gateway/starter/src/main/java/org/eclipse/ditto/services/gateway/starter/GatewayRootActor.java (diff)
The file was modifiedservices/gateway/util/src/main/java/org/eclipse/ditto/services/gateway/util/GatewayMappingStrategies.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JsonWebToken.java (diff)
The file was modifiedservices/gateway/security/src/test/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtAuthenticationProviderTest.java (diff)
The file was modifiedservices/gateway/util/pom.xml (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/directives/auth/DittoGatewayAuthenticationDirectiveFactory.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/StreamingAck.java (diff)
The file was addedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/JwtToken.java
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/ProtocolMessageExtractorTest.java (diff)
The file was addedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/ResetSessionTimer.java
The file was modifiedservices/gateway/security/src/test/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/AbstractJsonWebTokenTest.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingActor.java (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/client-sdk-java.md (diff)
The file was modifiedservices/gateway/security/src/test/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtTestConstants.java (diff)
The file was addedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtValidator.java
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtAuthenticationProvider.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/AbstractJsonWebToken.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/ProtocolMessageExtractor.java (diff)
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/routes/RootRouteTest.java (diff)
The file was modifiedservices/gateway/streaming/pom.xml (diff)
Commit 5df7a0a396306208fc66143e5314a07121ef3549 by Thomas J??ckle
disabled URI path validation as there could be placeholders in it
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushValidator.java (diff)
Commit cc8f5c82c846f003302dfc1cd34c6165880d5446 by noreply
fixed propoprtions of height of adopter logos on website
The file was modifieddocumentation/src/main/resources/css/customstyles.css (diff)
Commit 3e834c0e85838ecb75d5c54549f1e399b54cf272 by Florian Fendt
Do not allow multiple slashes in JSON pointers - throw an exception
instead
Signed-off-by: Florian Fendt <Florian.Fendt@bosch-si.com>
The file was modifiedjson/src/main/java/org/eclipse/ditto/json/ImmutableJsonPointer.java (diff)
The file was modifiedjson/src/main/java/org/eclipse/ditto/json/JsonPointerInvalidException.java (diff)
The file was modifiedjson/src/test/java/org/eclipse/ditto/json/ImmutableJsonPointerTest.java (diff)
The file was addedjson/src/test/java/org/eclipse/ditto/json/JsonPointerInvalidExceptionTest.java
Commit 779e1fcd83be26ac088e8e83297ce79e6194648f by Florian Fendt
Do not longer merge double slashes in the REST endpoints
Signed-off-by: Florian Fendt <Florian.Fendt@bosch-si.com>
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/stats/StatsRoute.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/devops/DevOpsRoute.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/thingsearch/ThingSearchRoute.java (diff)
The file was removedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/directives/CustomPathMatchers.java
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/things/FeaturesRoute.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/RootRoute.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/policies/PoliciesRoute.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/things/MessagesRoute.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/things/ThingsRoute.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/status/OverallStatusRoute.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/policies/PolicyEntriesRoute.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/sse/SseThingsRoute.java (diff)
Commit b45091bcf0c3f93af1b1eca707b8a4e278e566bf by Florian Fendt
fix test of ThingsRoute which does not longer get an
AttributePointerInvalidException
Signed-off-by: Florian Fendt <Florian.Fendt@bosch-si.com>
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/routes/things/ThingsRouteTest.java (diff)
Commit cf119e6537de46d6d1fe687a4a04c7258cb7dd71 by Thomas J??ckle
added documentation about new ConnectionType "http-push"
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifieddocumentation/src/main/resources/pages/ditto/connectivity-tls-certificates.md (diff)
The file was addeddocumentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-http.md
The file was modifieddocumentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-kafka2.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/architecture-overview.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/protocol-bindings.md (diff)
The file was modifieddocumentation/src/main/resources/jsonschema/connection.json (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-connections.md (diff)
The file was addeddocumentation/src/main/resources/_posts/2019-10-02-http-connectivity.md
The file was modifieddocumentation/src/main/resources/_data/sidebars/ditto_sidebar.yml (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/architecture-services-connectivity.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/connectivity-overview.md (diff)
Commit 59859de88947fde1dfc1e007e72fd91de7cf809e by Thomas J??ckle
prevent the state timeout canceling when switching to UNKNOWN state *
this caused that a client which should be connected did not connect at
all after service restart * reduced logging of SubUpdater which did a
lot of noise on debug level
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubUpdater.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
Commit eddb07f2f76dc99c526c3272973b16640ca7b863 by yufei.cai
Set default Http-push queue size to 100.
Maximum memory consumption per Http-push connection is then 10 MB.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
Commit 7f657ce5393e11e94cd17641d6cf98a531972358 by yufei.cai
Refactor blocking wait into future.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherActor.java (diff)
Commit e9b138c9b82dec5d18451f7e74184e81dad49781 by Yannic Klem
Add final keyword and improve javadoc
Signed-off-by: Klem Yannic (INST/ECS1) <yannic.klem@bosch-si.com>
The file was modifiedservices/utils/namespaces/src/main/java/org/eclipse/ditto/services/utils/namespaces/BlockNamespaceBehavior.java (diff)
The file was modifiedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/JavaTestProbe.java (diff)
Commit 36e8539522f44d0568b00718bd715b9d151b248c by stefan.maute
fixed AbstractJsonWebTokenTest; add method to JsonWebToken to check
expiration of token;
Signed-off-by: Stefan Maute <stefan.maute@bosch-si.com>
The file was modifiedservices/gateway/starter/src/test/java/org/eclipse/ditto/services/gateway/starter/GatewayServiceGlobalCommandResponseRegistryTest.java (diff)
The file was modifiedservices/gateway/security/src/test/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/AbstractJsonWebTokenTest.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JsonWebToken.java (diff)
The file was modifiedservices/gateway/security/src/test/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtTestConstants.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/AbstractJsonWebToken.java (diff)
Commit ad3539e9b52ab95119cbc0502e5aaec11bc4f1ca by Thomas J??ckle
configure resource limits for memory for helm templates, fixes #502
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifieddeployment/helm/eclipse-ditto/templates/things.yaml (diff)
The file was modifieddeployment/openshift/mongodb/mongodb.yaml (diff)
The file was modifieddeployment/helm/eclipse-ditto/values.yaml (diff)
The file was modifieddeployment/helm/eclipse-ditto/templates/gateway.yaml (diff)
The file was modifieddeployment/helm/eclipse-ditto/templates/policies.yaml (diff)
The file was modifieddeployment/openshift/ditto/ditto-cluster.yaml (diff)
The file was modifieddeployment/helm/eclipse-ditto/templates/concierge.yaml (diff)
The file was modifieddeployment/helm/eclipse-ditto/templates/connectivity.yaml (diff)
The file was modifieddeployment/helm/eclipse-ditto/templates/search.yaml (diff)
Commit 4c0a6e2f1185151a4cdfb7fe9d5150490d828759 by Alexander Wellbrock
Add docs about the openid connect feature
The overall documentation is for once extracted from the blog post about
OIDC and verfified with an keycloak and keycloak-gatekeeper setup.
https://www.eclipse.org/ditto/2019-08-28-openid-connect.html
For the user / operator of ditto to know how the subject is addressed
and that OIDC is a valid option in the context of authorization, an
additional bullet-point is added to the list on basic-policy. A list of
certified providers shall aid at this point.
To avoid confusion about the extend of the OIDC implementation, this
adds a notice that tokens have to be issued beforehand and
keycloak-gatekeeper is used as an example application. This is because
keycloak is a common and certified provider and gatekeeper is maintained
by the same team.
Signed-off-by: Alexander Wellbrock <a.wellbrock@mailbox.org>
Update token issue notice in the operator docs
This won't be part of ditto any time soon (if ever).
Co-Authored-By: Johannes Schneider <johannes.schneider@bosch-si.com> Fix
typo in keycloak md link
Co-Authored-By: Johannes Schneider <johannes.schneider@bosch-si.com>
Signed-off-by: Alexander Wellbrock <a.wellbrock@mailbox.org>
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-policy.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/installation-operating.md (diff)
Commit 0a7b81bb3d0022cf81482313ae444ad0a2fd1f4b by Thomas J??ckle
updated publishing date of blogpost about HTTP connections
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was addeddocumentation/src/main/resources/_posts/2019-10-10-http-connectivity.md
The file was removeddocumentation/src/main/resources/_posts/2019-10-02-http-connectivity.md
Commit bdac2570cfbbf2b0a3beeca1f60c04be44022680 by Thomas J??ckle
updated context-overview.png image by adding HTTP based connections
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifieddocumentation/src/main/resources/images/pages/architecture/context-overview.png (diff)
Commit ea98201086746cacc220990a4066804a361a411f by Johannes Kraeher
#17 moved JsonWebToken to model
Signed-off-by: krj1imb <johannes.schneider@bosch-si.com>
The file was modifiedservices/gateway/starter/src/test/java/org/eclipse/ditto/services/gateway/starter/GatewayServiceGlobalErrorRegistryTest.java (diff)
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/DittoJwtAuthorizationSubjectsProvider.java (diff)
The file was addedservices/gateway/security/src/test/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtValidatorTest.java
The file was removedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtAudienceInvalidException.java
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtAuthorizationContextProvider.java (diff)
The file was addedmodel/base/src/test/java/org/eclipse/ditto/model/base/common/BinaryValidationResultTest.java
The file was removedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/ImmutableJsonWebToken.java
The file was addedmodel/jwt/src/test/java/org/eclipse/ditto/model/jwt/ImmutableJsonWebTokenTest.java
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtAuthorizationSubjectsProvider.java (diff)
The file was removedservices/gateway/security/src/test/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/ImmutableJsonWebTokenTest.java
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/DefaultJwtAuthorizationContextProvider.java (diff)
The file was removedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/ImmutableJsonWebKey.java
The file was modifiedservices/gateway/security/src/test/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/DefaultJwtAuthorizationContextProviderTest.java (diff)
The file was modifiedsignals/commands/base/pom.xml (diff)
The file was addedmodel/jwt/src/test/java/org/eclipse/ditto/model/jwt/ImmutableJsonWebKeyTest.java
The file was addedmodel/jwt/src/test/java/org/eclipse/ditto/model/jwt/AudienceTest.java
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebsocketRoute.java (diff)
The file was addedmodel/base/src/main/java/org/eclipse/ditto/model/base/common/BinaryValidationResult.java
The file was removedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JsonWebKey.java
The file was removedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtException.java
The file was removedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/AbstractJsonWebToken.java
The file was addedmodel/jwt/src/main/java/org/eclipse/ditto/model/jwt/JwtAudienceInvalidException.java
The file was modifiedbom/pom.xml (diff)
The file was removedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/BinaryValidationResult.java
The file was modifiedmodel/pom.xml (diff)
The file was addedmodel/jwt/src/main/java/org/eclipse/ditto/model/jwt/ImmutableJsonWebToken.java
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtValidator.java (diff)
The file was removedservices/gateway/security/src/test/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/BinaryValidationResultTest.java
The file was addedmodel/jwt/src/main/java/org/eclipse/ditto/model/jwt/JsonWebKey.java
The file was addedmodel/jwt/src/main/java/org/eclipse/ditto/model/jwt/JwtInvalidException.java
The file was addedmodel/jwt/pom.xml
The file was addedmodel/jwt/src/main/java/org/eclipse/ditto/model/jwt/JsonWebToken.java
The file was removedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayJwtInvalidException.java
The file was removedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JsonWebToken.java
The file was modifiedservices/gateway/security/pom.xml (diff)
The file was addedmodel/jwt/src/main/java/org/eclipse/ditto/model/jwt/Audience.java
The file was removedservices/gateway/security/src/test/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/AudienceTest.java
The file was removedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/Audience.java
The file was addedmodel/jwt/src/main/java/org/eclipse/ditto/model/jwt/ImmutableJsonWebKey.java
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtAuthenticationProvider.java (diff)
The file was modifiedservices/gateway/security/src/test/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtAuthenticationProviderTest.java (diff)
The file was removedservices/gateway/security/src/test/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/AbstractJsonWebTokenTest.java
The file was addedmodel/jwt/src/main/java/org/eclipse/ditto/model/jwt/JwtException.java
The file was addedmodel/jwt/src/main/java/org/eclipse/ditto/model/jwt/package-info.java
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/DittoPublicKeyProvider.java (diff)
The file was removedservices/gateway/security/src/test/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/ImmutableJsonWebKeyTest.java
The file was addedmodel/jwt/src/main/java/org/eclipse/ditto/model/jwt/AbstractJsonWebToken.java
Commit 4ac0ed340374beb2067053e4eb6af1353cbbd036 by Johannes Kraeher
#17 fixed compile errors
Signed-off-by: krj1imb <johannes.schneider@bosch-si.com>
The file was modifiedservices/gateway/starter/src/main/java/org/eclipse/ditto/services/gateway/starter/GatewayRootActor.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingActor.java (diff)
Commit 674bd3027a3434f498d35765ebf929b925617fe0 by yufei.cai
Test multiple client actors; disregard ack from remotely deployed client
actors.
Reason: Remotely deployed actors are not started right away when their
router starts. Given how much error handling is required for remote
actor lifecycle management, it is better to ignore remote actors
altogether and let them start and stop on their own. With that, we rely
on the correctness of desired status and that client actors release all
resources when they stop.
Also splitted the client actor state UNKNOWN into UNKNOWN and
INITIALIZING. The state UNKNOWN is for permanently failed clients, and
the state INITIALIZING has a short timeout to start remote client actors
as soon as possible without any signal from the connection persistent
actor.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/stages/ConnectionAction.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionPersistenceActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/AbstractMqttClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientState.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/resources/test.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/ResetConnectionLogsStrategy.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/EnableConnectionLogsStrategy.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/ResetConnectionMetricsStrategy.java (diff)
Commit 3103957d98550d6d804ac0ebb411c939d585a710 by yufei.cai
PubSubFactoryTest.startSeveralTimes: Reduce probability of failure
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactoryTest.java (diff)
Commit a3073b064ee295e96b469e9d19e4ff6f5fe62c96 by yufei.cai
Fix typo
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
Commit 12aad12b2a9ada491eae30fc9b66ee2f3dec1fa2 by noreply
removed dead "else" branch
oversaw that in review :(
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
Commit 50e09836d92fc64f3864b55207377c8c9c93f3bd by yufei.cai
Http-push: support basic auth.
User info in URI is not automatically converted to basic auth header.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactoryTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/DefaultHttpPushFactory.java (diff)
Commit 03befcaf7cb8e99d43b632b0b68ef711bef84d45 by dominik.guggemos
change MessageMapper API to support multiple messages as result
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/DittoMessageMapper.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/javascript/JavaScriptMessageMapperRhinoTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/custom/ConnectionStatusMessageMapperTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/MessageMapper.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/WrappingMessageMapperTest.java (diff)
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/UnmodifiableExternalMessage.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/javascript/benchmark/JavaScriptMessageMapperRhinoBenchmarkTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessor.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/WrappingMessageMapper.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/custom/ConnectionStatusMessageMapper.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/javascript/JavaScriptMessageMapperRhino.java (diff)
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/UnmodifiableExternalMessageBuilder.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/test/MockMapper.java (diff)
Commit 3ff47770c152043dc272db54bc845af77827c989 by yufei.cai
Fix sonar findings.
Of 17 findings:
- 1 is non-throwing of NoSuchElementException in StagedCommand.next()
- 1 is potential for NullPointerException in JjwtSerializer
- 15 are false positives fixed by shuffling code around
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedservices/utils/jwt/src/main/java/org/eclipse/ditto/services/utils/jwt/JjwtSerializer.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/RetrieveSubjectStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/RetrieveResourceStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/RetrieveSubjectsStrategy.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/JMSConnectionHandlingActor.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/DeletePolicyEntryStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifySubjectsStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifyResourceStrategy.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/stages/StagedCommand.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/DeleteSubjectStrategy.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/events/ConnectionClosedStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/DeleteResourceStrategy.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/events/ConnectionOpenedStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifySubjectStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifyPolicyEntryStrategy.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/events/PolicyEntriesModifiedStrategy.java (diff)
Commit 796d10ca0ebe1d61f8b2b2bf161543e7147db82e by yufei.cai
Fix random reordering by JsonFieldSelector.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedjson/src/main/java/org/eclipse/ditto/json/JsonFieldSelectorTrie.java (diff)
The file was modifiedjson/src/test/java/org/eclipse/ditto/json/ImmutableJsonObjectTest.java (diff)
The file was modifiedjson/src/test/java/org/eclipse/ditto/json/ImmutableJsonFieldSelectorTest.java (diff)
Commit 086bdf42f9c0cfd12d156391d0d0836dd38b2a47 by dominik.guggemos
fix unit tests
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/javascript/ScriptedIncomingMapping.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/DittoMessageMapperTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/javascript/ScriptedOutgoingMapping.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/javascript/JavaScriptMessageMapperRhinoTest.java (diff)
Commit 265243582d079a5b9c043dd31a9026792229a107 by Alexander Wellbrock
Enhance docs of docker deployment (fixes #443)
Add entrypoint section to compose file
To make it more obvious for the operator how a service may be configured
the entrypoint section used for the services is now explicitly part of
the compose file.
This way someone new to ditto and java has a better chance of
understanding how the services may be configured.
Add short summary on config to docker readme
To make it more clear this commit adds a section on configuration to the
docker deployment readme. This section handles two topics.
First the mechanics of a java application configuration are laid out.
The configuration is depicted via the entrypoint section of the
compose-file. This approach is chosen, because it enables a fairly easy
configuration of the java service via the java VM parameters. The chosen
example is the devops command from the gateway service due to it's
practicability and importance when setting up an instance for oneself.
Second follows a description on how to retrieve possible configuration
options either via HTTP REST API or via the given configuration files in
the repository. This should enable more people to faster learn how to
work with and configure each service.
Add a config section to operational docs
To enhance the understanding for configuration of the ditto
micro-services this commit adds a configuration section to the public
docs for operators. It contains a docker-specific example and hints on
where to find available configuration options.
This is necessary to give operators new to ditto and java applications a
better start on hosting and using their own instances of ditto.
Remove misleading configuration from sandbox
This will remove confusing and unecessary configuration from the sandbox
in the docker deployment.
Setting a devops user and password basic auth before the devops route is
not just uneccessary, because this is configured in the gateway service
already, it's also misleading to new operators of ditto.
This is an enhancement with regard to #443
Signed-off-by: Alexander Wellbrock <a.wellbrock@mailbox.org>
The file was removeddeployment/docker/sandbox/nginx-devops.htpasswd
The file was modifieddeployment/docker/README.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/installation-operating.md (diff)
The file was modifieddeployment/docker/sandbox/nginx.conf (diff)
The file was modifieddeployment/docker/docker-compose.yml (diff)
Commit 20ce41fe2f30402702721a79d7776f92e2dacd24 by Thomas J??ckle
fixed bug that etag for ModifyPolicyEntryStrategy and
DeletePolicyEntryStrategy was calculated wrong -> an optional was passed
in instead of the actual entity
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/DeletePolicyEntryStrategy.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/AbstractCommandStrategy.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractPersistenceSupervisor.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/entitytag/EntityTagBuilder.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/ModifyPolicyEntryStrategy.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/entitytag/EntityTag.java (diff)
Commit af17630c7f7d59d6f968b39c514cbabdf2fca13d by Thomas J??ckle
fixed review findings on Ditto documentation
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifieddocumentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-amqp091.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-amqp10.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-http.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-kafka2.md (diff)
The file was modifieddocumentation/src/main/resources/pages/ditto/connectivity-protocol-bindings-mqtt.md (diff)
The file was modifieddocumentation/src/main/resources/_posts/2019-10-10-http-connectivity.md (diff)
Commit e6cd4f4560808cccf56ceafc900a9bb06b31e9f6 by Thomas J??ckle
configured user-agent as "eclipse-ditto/<version>" for outgoing HTTP
calls
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was modifiedservices/utils/config/src/main/resources/ditto-service-base.conf (diff)
The file was modifiedservices/utils/config/pom.xml (diff)
The file was modifiedservices/gateway/starter/src/main/resources/gateway.conf (diff)
Commit 94aaf3bf64b50eec91e775ce2bb9caa60a3b0265 by yufei.cai
ImmutableJsonObjectTest: test order of parenthetical selectors.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedjson/src/test/java/org/eclipse/ditto/json/ImmutableJsonObjectTest.java (diff)
Commit 55456bbdcb7e6bfa1cb333fe531f90c9c0c24482 by stefan.maute
instantiate JwtAuthorizationContextProvider in GatewayRootActor; extract
and check Authorization Context from new JWT; terminate ws session if
auth context changed;
Signed-off-by: Stefan Maute <stefan.maute@bosch-si.com>
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
The file was addedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/RefreshSession.java
The file was addedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayWebsocketSessionClosedException.java
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayWebsocketSessionExpiredException.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebsocketRoute.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/directives/auth/DittoGatewayAuthenticationDirectiveFactory.java (diff)
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/routes/RootRouteTest.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/EventAndResponsePublisher.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingActor.java (diff)
The file was modifiedservices/gateway/starter/src/main/java/org/eclipse/ditto/services/gateway/starter/GatewayRootActor.java (diff)
The file was removedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/ResetSessionTimer.java
Commit f5f2e5f33ad39117a55a192ad95c9d6e83132a5a by dominik.guggemos
add some more mapping tests
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/DuplicatingMessageMapper.java
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/DroppingMessageMapper.java
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/javascript/ScriptedIncomingMapping.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/javascript/ScriptedOutgoingMapping.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQConsumerActor.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMessageMapperRegistry.java (diff)
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorTest.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActorTest.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectivityModelFactory.java (diff)
The file was addedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMessageMapperRegistryTest.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQClientActor.java (diff)
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/FaultyMessageMapper.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractConsumerActorTest.java (diff)
Commit 26d5af234de40652dc04cc8791dbe9e2e3f49863 by dominik.guggemos
set mapper id from connection config
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/custom/ConnectionStatusMessageMapper.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/javascript/benchmark/Test4ConstructJsonPayloadToDitto.java (diff)
The file was addedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/AbstractMessageMapper.java
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMessageMapperConfiguration.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/javascript/benchmark/Test1DecodeBinaryPayloadToDitto.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/javascript/benchmark/SimpleMapTextPayloadToDitto.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/javascript/JavaScriptMessageMapperRhinoTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/DittoMessageMapper.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/javascript/benchmark/Test2ParseJsonPayloadToDitto.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/javascript/benchmark/Test5DecodeBinaryToDitto.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/custom/ConnectionStatusMessageMapperTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/javascript/JavaScriptMessageMapperRhinoSandboxingTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/MessageMapperConfiguration.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/javascript/JavaScriptMessageMapperRhino.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/test/MockMapper.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/MessageMapperFactory.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/javascript/ImmutableJavaScriptMessageMapperConfiguration.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/MessageMappers.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMessageMapperFactory.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMessageMapperFactoryTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/javascript/JavaScriptMessageMapperFactory.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/javascript/benchmark/Test3FormatJsonPayloadToDitto.java (diff)
Commit a0272117125564005d35f8814d02852ba030011a by Johannes Kraeher
#17 [WIP] implemented token refresh
Signed-off-by: krj1imb <johannes.schneider@bosch-si.com>
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtAuthenticationProvider.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingActor.java (diff)
The file was modifiedmodel/jwt/src/main/java/org/eclipse/ditto/model/jwt/AbstractJsonWebToken.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebsocketRoute.java (diff)
The file was modifiedservices/gateway/security/src/test/java/org/eclipse/ditto/services/gateway/security/authentication/jwt/JwtValidatorTest.java (diff)
The file was modifiedmodel/jwt/src/main/java/org/eclipse/ditto/model/jwt/ImmutableJsonWebToken.java (diff)
The file was modifiedmodel/jwt/src/test/java/org/eclipse/ditto/model/jwt/ImmutableJsonWebTokenTest.java (diff)
Commit d5a8c28b7087f469522917d8a752a3ec27e9bed7 by dominik.guggemos
add mapper used to process inbound messages to internal headers and use
it to map responses with same mapper
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/WrappingMessageMapper.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMessageMapperRegistry.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorTest.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeaderDefinition.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMessageMapperRegistryTest.java (diff)
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AddHeaderMessageMapper.java
Commit 4da27e1f4cd148a2b87a060b1a9ec4cfed2c73f9 by dominik.guggemos
add methods to get and set mapper value from ditto headers and use them
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeaders.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorTest.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeadersBuilder.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/AbstractDittoHeaders.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/AbstractDittoHeadersBuilder.java (diff)
The file was modifiedmodel/base/src/test/java/org/eclipse/ditto/model/base/headers/ImmutableDittoHeadersTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessor.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/WrappingMessageMapper.java (diff)
Commit 1752d81d1c796ae5f87cb173972aabda2ff6d028 by yufei.cai
Extract HttpProxyConfig from Gateway and reuse it for Http-push
connections.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/HttpPushConfig.java (diff)
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/config/DefaultAuthenticationConfigTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/DefaultHttpPushFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactoryTest.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/config/DefaultAuthenticationConfig.java (diff)
The file was addedservices/base/src/main/java/org/eclipse/ditto/services/base/config/http/HttpProxyConfig.java
The file was removedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/config/DefaultHttpProxyConfigTest.java
The file was addedservices/base/src/test/resources/http-proxy-test.conf
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/utils/DefaultHttpClientFacade.java (diff)
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was addedservices/base/src/main/java/org/eclipse/ditto/services/base/config/http/DefaultHttpProxyConfig.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActor.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/config/AuthenticationConfig.java (diff)
The file was addedservices/base/src/test/java/org/eclipse/ditto/services/base/config/http/DefaultHttpProxyConfigTest.java
The file was removedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/config/DefaultHttpProxyConfig.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultHttpPushConfig.java (diff)
The file was removedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/config/HttpProxyConfig.java
The file was modifiedservices/connectivity/messaging/src/test/resources/test.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactory.java (diff)
Commit db5ddd182eace8e9cb7fe11375b57bfa55e80f4f by yufei.cai
Stabilize MqttClientActorTest.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/AbstractMqttClientActorTest.java (diff)
Commit 11414aafe97ffbd1eae5189402bb45c183a6c948 by stefan.maute
send an acknowledge when a new JWT token was received over WS; handle
GatewayWebsocketSessionExpiredException and
GatewayWebsocketSessionClosedException in websocket stream;
Signed-off-by: Stefan Maute <stefan.maute@bosch-si.com>
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/JwtToken.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebsocketRoute.java (diff)
The file was addedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/InvalidJwtToken.java
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingActor.java (diff)
The file was addedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/JwtTokenAck.java
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
Commit 06c36ca951f94c64f98bb3d6ebab5eba5ff092d6 by dominik.guggemos
introduce types PayloadMappingDefinition and PayloadMapping in
connectivity model
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/Connection.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActorTest.java (diff)
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/ExternalMessageBuilder.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ImmutableConnection.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingResultHandler.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQConsumerActor.java (diff)
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/UnmodifiableExternalMessage.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/MessageMapperFactory.java (diff)
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/ExternalMessage.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractConsumerActorTest.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/Source.java (diff)
The file was modifiedmodel/connectivity/src/test/java/org/eclipse/ditto/model/connectivity/ImmutableTargetTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMessageMapperRegistry.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/Target.java (diff)
The file was addedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ImmutablePayloadMappingDefinition.java
The file was modifiedmodel/connectivity/src/test/java/org/eclipse/ditto/model/connectivity/ImmutableSourceTest.java (diff)
The file was addedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ImmutablePayloadMapping.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQClientActor.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectivityModelFactory.java (diff)
The file was addedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/PayloadMapping.java
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ImmutableSource.java (diff)
The file was addedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/PayloadMappingDefinition.java
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/MessageMapperRegistry.java (diff)
The file was addedmodel/connectivity/src/test/java/org/eclipse/ditto/model/connectivity/ImmutablePayloadMappingDefinitionTest.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActor.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMessageMapperFactory.java (diff)
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/UnmodifiableExternalMessageBuilder.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/SourceBuilder.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorTest.java (diff)
The file was modifiedmodel/connectivity/src/test/java/org/eclipse/ditto/model/connectivity/ImmutableConnectionTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessor.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMessageMapperFactoryTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingResultHandler.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ImmutableTarget.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MappingResultHandler.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ConnectionBuilder.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/TargetBuilder.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMessageMapperRegistryTest.java (diff)
Commit f2044d9bc8a5c4262dbfdb95227a268448343a62 by yufei.cai
Add stream component LimitRateByRejection and prepend it to websockets.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was addedmodel/base/src/main/java/org/eclipse/ditto/model/base/exceptions/TooManyRequestsException.java
The file was addedmodel/base/src/test/java/org/eclipse/ditto/model/base/exceptions/TooManyRequestsExceptionTest.java
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/controlflow/Filter.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebsocketRoute.java (diff)
The file was addedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/controlflow/LimitRateByRejection.java
Commit 66e7d84325c863355376cd79055c8a1ca5011d28 by Thomas J??ckle
added validation of MappingContexts in AbstractProtocolValidator and
used it for all protocol validators
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/DittoConnectivityCommandValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/MqttValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/AbstractProtocolValidator.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMessageMapperFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaValidatorTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/NormalizedMessageMapper.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/MqttValidatorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQValidatorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpValidator.java (diff)
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushValidatorTest.java
Commit bab4d83c8ccdace5734aaf53987ca9b3fe5ebae9 by dominik.guggemos
fix test
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/models/connectivity/src/test/java/org/eclipse/ditto/services/models/connectivity/UnmodifiableExternalMessageTest.java (diff)
Commit 244a1081974be6439d58ce1496cca608325a8e32 by dominik.guggemos
add javadoc, fix handling of null PayloadMapping in ExternalMessage
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/UnmodifiableExternalMessageBuilder.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMessageMapperFactory.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/PayloadMapping.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MappingTimer.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/AbstractMessageMapper.java (diff)
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/ExternalMessage.java (diff)
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/UnmodifiableExternalMessage.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessor.java (diff)
Commit 202e8bf2fc27df2d3adce3f6b64d5f27c96030ef by dominik.guggemos
fix javadoc errors
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingResultHandler.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingResultHandler.java (diff)
Commit e86ccf3e8ec621d2dac352c715e9f8e3b6f2a6f7 by noreply
made width of adopter logos relative in percent
The file was modifieddocumentation/src/main/resources/css/customstyles.css (diff)
Commit 3252c64e5fd4c49ce022d27456371eba8687b93e by dominik.guggemos
review ConnectionStatusMessageMapper
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/custom/ConnectionStatusMessageMapperTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/custom/ConnectionStatusMessageMapper.java (diff)
Commit 6a4fc8712d94f19684d50a2bad6d9cb57d77f8d5 by Florian Fendt
implement reconnect back-off mechanism for targets in amqp connections
-----------
This is needed since there is a reconnect loop if the used JMS client
gets an error after connecting successfully. This can be e.g. an
authorization error which is thrown after the connection initially could
be established. This will cause a retry for the target. Since the
configuration seems to be wrong for that point in time, the connection
will be looping through opening, getting disconnected and reopening the
target.
As the target should get opened successfully when the endpoints accepts
it, it makes sense to continue retrying the connection. That's why a
back-off mechanism makes sense. On connection error, the PublisherActor
will now back-off for some time until trying to reconnect. The back-off
duration can be configured using the config keys
ditto.connectivity.amqp10.backoff.timeout.[min-timeout, max-timeout].
The current implementation will double the previous timeout until
max-timeout is reached.
Signed-off-by: Florian Fendt <Florian.Fendt@bosch-si.com>
The file was addedservices/connectivity/messaging/src/test/resources/backoff-test.conf
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/backoff/BackOffConfig.java
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/backoff/DefaultTimeoutConfigTest.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultAmqp10Config.java (diff)
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/backoff/DefaultBackOffConfigTest.java
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/Amqp10Config.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/backoff/DefaultBackOffConfig.java
The file was addedservices/connectivity/messaging/src/test/resources/timeout-test.conf
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActor.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/backoff/BackOffActor.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/backoff/RetryTimeoutStrategy.java
The file was modifiedservices/connectivity/messaging/src/test/resources/test.conf (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/backoff/DefaultTimeoutConfig.java
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/backoff/TimeoutConfig.java
The file was modifiedservices/connectivity/messaging/src/test/resources/connection-test.conf (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/backoff/DuplicationRetryTimeoutStrategy.java
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/backoff/BackOffActorTest.java
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/backoff/DuplicationRetryTimeoutStrategyTest.java
Commit 6c4c9acbe299d3ff92b44905ca60c000f18f58f2 by Florian Fendt
fix missing config value on amqp10.backoff.timeout for test and use
defaults in DefaultBackOffConfig
Signed-off-by: Florian Fendt <Florian.Fendt@bosch-si.com>
The file was modifiedservices/connectivity/starter/src/test/resources/test.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/backoff/DefaultBackOffConfig.java (diff)
Commit 72d26c38e8b9fe585b5cd3cca19d3d76eb099abf by Thomas J??ckle
review: added using HttpProxyConf to HttpPushClientActor * added a
host/port check via HTTP proxy ("CONNECT")
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/base/src/main/java/org/eclipse/ditto/services/base/config/http/DefaultHttpProxyConfig.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/DefaultHttpPushFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActor.java (diff)
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
Commit 70597e710be14bfb673c062744816d54258ca2ef by yufei.cai
Load websocket config dynamically on each upgrade-to-websocket request.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was addedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/WebsocketConfig.java
The file was addedservices/base/src/main/java/org/eclipse/ditto/services/base/config/ThrottlingConfig.java
The file was removedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/config/DefaultWebSocketConfig.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/Amqp10Config.java (diff)
The file was addedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/DefaultWebsocketConfig.java
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/routes/RootRouteTest.java (diff)
The file was modifiedservices/gateway/starter/src/main/java/org/eclipse/ditto/services/gateway/starter/config/GatewayConfig.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultConnectionConfigTest.java (diff)
The file was addedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/package-info.java
The file was addedservices/base/src/test/resources/throttling-test.conf
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebsocketRoute.java (diff)
The file was addedservices/base/src/main/java/org/eclipse/ditto/services/base/config/DefaultThrottlingConfig.java
The file was addedservices/base/src/test/java/org/eclipse/ditto/services/base/config/DefaultThrottlingConfigTest.java
The file was removedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/config/DefaultWebSocketConfigTest.java
The file was removedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/config/WebSocketConfig.java
The file was removedservices/gateway/endpoints/src/test/resources/websocket-test.conf
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/ProtocolMessageExtractor.java (diff)
The file was modifiedservices/gateway/starter/src/main/resources/gateway.conf (diff)
The file was addedservices/gateway/streaming/src/test/resources/websocket-test.conf
The file was modifiedservices/gateway/starter/src/main/java/org/eclipse/ditto/services/gateway/starter/GatewayRootActor.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultAmqp10Config.java (diff)
The file was addedservices/gateway/streaming/src/test/java/org/eclipse/ditto/services/gateway/streaming/DefaultWebsocketConfigTest.java
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/EndpointTestBase.java (diff)
The file was modifiedservices/gateway/streaming/pom.xml (diff)
The file was modifiedservices/gateway/starter/src/main/java/org/eclipse/ditto/services/gateway/starter/config/DittoGatewayConfig.java (diff)
Commit 909bdb243e2d3423f97972d1decb3547b4b002c8 by Thomas J??ckle
fixed that clientTransport is only created when http proxy is enabled
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/test/resources/logback-test.xml (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/DefaultHttpPushFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/resources/test.conf (diff)
Commit 8f739bb1271d080c4a69c971a95bfcf25e84cfe1 by yufei.cai
Improve formatting and connection error log on JSON errors.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedsignals/base/src/main/java/org/eclipse/ditto/signals/base/AnnotationBasedJsonParsable.java (diff)
The file was modifiedservices/utils/devops/src/main/java/org/eclipse/ditto/services/utils/devops/DevOpsCommandsActor.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/exceptions/DittoJsonException.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/DefaultHttpPushFactory.java (diff)
Commit b8076aa1c116d3743f0b3705cdcf2dbb7db392d2 by Thomas J??ckle
re-added explicit type <T>
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/DefaultHttpPushFactory.java (diff)
Commit c9cbccee1150ec509a076c51489e68bb83255066 by Thomas J??ckle
added logging for request URI to connection logs
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushContext.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactory.java (diff)
Commit af240be9d2692500ca6a99a1bbd3fa61d2baee6a by yufei.cai
Move websocket rate limiter after signal construction.
Reason: So that the error response retains the headers of the original
message.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebsocketRoute.java (diff)
Commit 473985246597f2114725e16206e9f24b05d01b30 by yufei.cai
WebsocketRoute: rearrange incoming stream.
Reason: Rate limiter should account for stream control messages that are
not part of the Ditto protocol.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/StreamingAck.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/StopStreaming.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/ProtocolMessageExtractor.java (diff)
The file was addedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/StreamControlMessage.java
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/StartStreaming.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebsocketRoute.java (diff)
Commit d4972359c16d246927ac29184074b7077ea871b3 by yufei.cai
Add counter for dropped WS messages.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebsocketRoute.java (diff)
Commit cb398d0900d220c1a3a6e3e379858c3fe1c6ef5e by yufei.cai
Modernize RootRoute; make CustomHeadersHandler asynchronous.
Reason: Prevent thread starvation due to blocking operations inside
CustomHeadersHandler.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/NoopCustomHeadersHandler.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/RootRoute.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/CustomHeadersHandler.java (diff)
Commit e81608300a063523f6b96d2c2ef7f2df9527658b by Thomas J??ckle
added hostname blacklisting for HTTP endpoints which should not be
invoked (e.g. localhost)
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/HttpPushConfig.java (diff)
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactoryTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/DefaultHttpPushFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultHttpPushConfig.java (diff)
Commit 539d1e91f4e92def9ddc76b6836833cc305d4d85 by Johannes Kraeher
#17 removed ack for jwt via websocket
Signed-off-by: krj1imb <johannes.schneider@bosch-si.com>
The file was removedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/JwtTokenAck.java
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayWebsocketSessionClosedException.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebsocketRoute.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/JwtToken.java (diff)
The file was addedsignals/commands/base/src/test/java/org/eclipse/ditto/signals/commands/base/exceptions/GatewayWebsocketSessionClosedExceptionTest.java
Commit ed4238243a3dc48db32629aa52490918136ff46c by yufei.cai
Add throttle stage to websocket to prevent rejections.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/WebsocketConfig.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/DefaultWebsocketConfig.java (diff)
The file was modifiedservices/gateway/streaming/src/test/resources/websocket-test.conf (diff)
The file was modifiedservices/gateway/starter/src/main/resources/gateway.conf (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebsocketRoute.java (diff)
The file was modifiedservices/gateway/streaming/src/test/java/org/eclipse/ditto/services/gateway/streaming/DefaultWebsocketConfigTest.java (diff)
Commit d97ae3100e97c388cf204bfb365b14b08ce3b3a0 by yufei.cai
Rename Ditto header "subject" to "ditto-subject" to avoid collision with
AMQP 1.0 property.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>
The file was modifiedservices/utils/config/src/main/resources/ditto-protocol.conf (diff)
The file was modifiedmodel/messages/src/main/java/org/eclipse/ditto/model/messages/MessageHeaderDefinition.java (diff)
Commit fe13160603d8f6806b6aec91e6b9e63cf984386d by Thomas J??ckle
removed configuring the max-parallelism - just check for valid number
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/connectivity/messaging/src/test/resources/test.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/HttpPushConfig.java (diff)
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultHttpPushConfig.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactoryTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultConnectionConfigTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/resources/connection-test.conf (diff)
Commit 1ef008af5dd65a0bf5df7c596a894f3cd5773dc5 by dominik.guggemos
replace loading of MessageMappers via its fully qualified class name by
an alias-based approach using the @PayloadMapper annotation
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was removedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/MessageMapperInstantiation.java
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/MappingConfig.java (diff)
The file was modified