SuccessChanges

Summary

  1. Add unit test for feature properties fields parameter (details)
  2. introduce WebSocketConfigProvider that is called before establishing a new web socket and allows the customization of the default websocket config (details)
  3. moved JsonObjectMerger into ditto-json; (details)
  4. unified test cases for JsonObjectMerger; (details)
  5. Implement limitation for sources and targets within a connection (details)
  6. add method to filter null values and empty objects in json objects; (details)
  7. adapt DefaultConnectionConfig and fix DefaultConnectionConfigTest; (details)
  8. moved connectivity config to separate module ditto-services-connectivity-common (details)
  9. use ConnectivityConfigProvider in ConnectionPersistenceActor and AmqpConsumerActor (details)
  10. fix missing license header (details)
  11. add missing semicolon (details)
  12. fix tests, clean up ConnectionValidator (details)
  13. add javadoc, add more unit tests (details)
  14. add required property to test config, fix tests (details)
  15. use ditto default config in ConnectionPersistenceActor (details)
  16. removed duplicate copyright header; (details)
  17. simplify ConnectivityConfigProvider, revert ssome previous changes (details)
  18. Extend validation for number of mapped messages (details)
  19. add timers to AbstractActorWithLock (details)
  20. fix several equals methods, remove empty MonitoringCounterConfig (details)
  21. fix unit test (details)
  22. handle connectivity config changes in BaseClientActor by creating a new MessageMappingProcessor (details)
  23. remove debug output (details)
  24. update base image version and add copyright header; (details)
  25. Fix unit test (details)
  26. Fix tests (details)
  27. Transform ThingsConnectivityConfigProvider into an extension to make it available when actor system is started e.g. when shard rebalancing happens. Remove ThingsConnectivityConfigProviderActor because it is not available that early on startup and resulted in ask timeouts. (details)
  28. fix unit test, remove debug output (details)
  29. more fine-grained handling of changes to mapping processor config in BaseClientActor (details)
  30. set ditto headers for mapping exception (details)
  31. fix initialization of OutboundMappingProcessor (details)
  32. change parameter type to int because maxNumber of source and target can not be a double; (details)
  33. Fix test error (details)
  34. update test case for JsonObjectMergerTest; (details)
  35. Exclude Javadoc generation for services.utils.akka.actors package to get mixed Scala/Java build to work. (details)
  36. Adjust javadoc comments (details)
  37. add since annotation to new method in JsonFactory (details)
Commit cd192a07b0a4c9b4fe56a66d521b8517e9be0bad by vadim.guenther
Add unit test for feature properties fields parameter

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
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/ETagTestUtils.java (diff)
Commit 9d9d20522f1b67a37e03d1d9f9696e7bd1e7686f by Dominik Guggemos
introduce WebSocketConfigProvider that is called before establishing a new web socket and allows the customization of the default websocket config

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was addedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebSocketConfigProvider.java
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebSocketRouteBuilder.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebSocketRoute.java (diff)
Commit 80f85f1dcf8d2f19fe1a781843a552cac01d4874 by Stefan Maute
moved JsonObjectMerger into ditto-json;
add method in JsonFactory to merge two jsonObjects;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was addedjson/src/test/java/org/eclipse/ditto/json/MergeJsonObjectsTest.java
The file was modifiedservices/utils/devops/src/main/java/org/eclipse/ditto/services/utils/devops/DevOpsCommandsActor.java (diff)
The file was removedmodel/enforcers/src/main/java/org/eclipse/ditto/model/enforcers/JsonObjectMerger.java
The file was removedmodel/enforcers/src/test/java/org/eclipse/ditto/model/enforcers/JsonObjectMergerTest.java
The file was removedmodel/enforcers/src/test/java/org/eclipse/ditto/model/enforcers/MergeJsonObjectsTest.java
The file was addedjson/src/test/java/org/eclipse/ditto/json/JsonObjectMergerTest.java
The file was addedjson/src/main/java/org/eclipse/ditto/json/JsonObjectMerger.java
The file was modifiedmodel/enforcers/src/main/java/org/eclipse/ditto/model/enforcers/Enforcer.java (diff)
The file was modifiedjson/src/main/java/org/eclipse/ditto/json/JsonFactory.java (diff)
The file was modifiedsignals/commands/devops/src/main/java/org/eclipse/ditto/signals/commands/devops/ExecutePiggybackCommand.java (diff)
Commit afab42724d05588568bb2f34364fb46aa7e5484a by Stefan Maute
unified test cases for JsonObjectMerger;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modifiedjson/src/main/java/org/eclipse/ditto/json/JsonObjectMerger.java (diff)
The file was removedjson/src/test/java/org/eclipse/ditto/json/MergeJsonObjectsTest.java
The file was modifiedjson/src/test/java/org/eclipse/ditto/json/JsonObjectMergerTest.java (diff)
Commit e0d7d24a3352a6256eb1c4bcac03f854b66443f7 by vadim.guenther
Implement limitation for sources and targets within a connection

*new default value is set to 4

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
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/TestConstants.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/validation/ConnectionValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/ConnectionConfig.java (diff)
The file was modifiedservices/connectivity/messaging/src/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/config/DefaultConnectionConfig.java (diff)
Commit acc2b58b457faa9f019ca7a57770317fc655aeb1 by Stefan Maute
add method to filter null values and empty objects in json objects;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modifiedjson/src/test/java/org/eclipse/ditto/json/JsonObjectMergerTest.java (diff)
The file was modifiedjson/src/main/java/org/eclipse/ditto/json/JsonObjectMerger.java (diff)
Commit 740213438258a8e90fbd965390603a98408e4658 by Stefan Maute
adapt DefaultConnectionConfig and fix DefaultConnectionConfigTest;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/resources/connection-test.conf (diff)
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/config/DefaultConnectionConfigTest.java (diff)
Commit 9e51a94f550239b0e8750a41add9002633a8f9cd by Dominik Guggemos
moved connectivity config to separate module ditto-services-connectivity-common

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQPublisherActor.java (diff)
The file was removedservices/connectivity/messaging/src/test/resources/client-test.conf
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/ConnectivityConfig.java
The file was removedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/MapperLimitsConfig.java
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultTimeoutConfig.java
The file was modifiedservices/connectivity/messaging/pom.xml (diff)
The file was modifiedservices/connectivity/mapping/pom.xml (diff)
The file was addedservices/connectivity/common/src/test/java/org/eclipse/ditto/services/connectivity/config/mapping/DefaultMappingConfigTest.java
The file was addedservices/connectivity/common/pom.xml
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/test/java/org/eclipse/ditto/services/connectivity/messaging/AddHeaderMessageMapper.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultMonitoringLoggerConfig.java
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/javascript/JavaScriptMessageMapperRhino.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultMonitoringLoggerConfig.java
The file was modifiedservices/connectivity/starter/src/main/java/org/eclipse/ditto/services/connectivity/actors/ConnectivityRootActor.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/ConnectionStatusMessageMapperTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/ImplicitThingCreationMessageMapperTest.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultMqttConfig.java
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigBuildable.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/kafka/ProducerPropertiesFactoryTest.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultMonitoringCounterConfig.java
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMessageMapperFactoryTest.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/package-info.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultReconnectConfig.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/backoff/DefaultBackOffConfig.java
The file was removedservices/connectivity/messaging/src/test/resources/connection-test.conf
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaClientActor.java (diff)
The file was addedservices/connectivity/common/src/test/resources/connection-test.conf
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/Amqp10Config.java
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/backoff/BackOffActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/HostValidatorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionSupervisorActor.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/javascript/JavaScriptConfig.java
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/javascript/DefaultJavaScriptConfigTest.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectionConfig.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/backoff/TimeoutConfig.java
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/persistence/ConnectionPersistenceActor.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultClientConfig.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultKafkaConfig.java
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultMonitoringCounterConfig.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/DuplicatingMessageMapper.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/RetrieveConnectionLogsAggregatorActorTest.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/javascript/DefaultJavaScriptConfig.java
The file was addedservices/connectivity/common/src/test/resources/backoff-test.conf
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/Amqp091Config.java
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/WrappingMessageMapper.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/config/DefaultHttpPushConfig.java
The file was addedservices/connectivity/common/src/test/java/org/eclipse/ditto/services/connectivity/config/DefaultMonitoringConfigTest.java
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/javascript/JavaScriptMessageMapperRhinoSandboxingTest.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/MonitoringCounterConfig.java
The file was removedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultConnectionConfigTest.java
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/mapping/DefaultMappingConfig.java
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/ConnectionStatusMessageMapper.java (diff)
The file was removedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/javascript/JavaScriptConfig.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherErrorTest.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ReconnectConfig.java
The file was removedservices/connectivity/messaging/src/test/resources/monitoring-test.conf
The file was modifiedservices/connectivity/pom.xml (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultMonitoringConfig.java
The file was removedservices/connectivity/messaging/src/test/resources/kafka-test.conf
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherActor.java (diff)
The file was removedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultReconnectConfigTest.java
The file was addedservices/connectivity/common/src/test/resources/mapper-limits-test.conf
The file was removedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMapperLimitsConfigTest.java
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/MessageMapper.java (diff)
The file was removedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMappingConfig.java
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigEvent.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActor.java (diff)
The file was removedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMappingConfigTest.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActor.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/HttpPushConfig.java
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/RawMessageMapper.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/MqttConfig.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/backoff/BackOffConfig.java
The file was removedservices/connectivity/mapping/src/test/resources/mapping-test.conf
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/mapping/MapperLimitsConfig.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/BasePublisherActor.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultMqttConfig.java
The file was removedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/DefaultMapperLimitsConfig.java
The file was removedservices/connectivity/mapping/src/test/resources/mapper-limits-test.conf
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultMonitoringConfig.java
The file was removedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultMonitoringConfigTest.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/ReconnectConfig.java
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/AbstractMessageMapper.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/ClientConfig.java
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultConnectionConfig.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorTest.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/MonitoringConfig.java
The file was addedservices/connectivity/common/src/test/java/org/eclipse/ditto/services/connectivity/config/mapping/DefaultMapperLimitsConfigTest.java
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/WrappingMessageMapperTest.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/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/javascript/benchmark/JavaScriptMessageMapperRhinoBenchmark.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/backoff/DuplicationRetryTimeoutStrategy.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/KafkaConfig.java
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/javascript/benchmark/MapToDittoProtocolScenario.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/backoff/DefaultTimeoutConfigTest.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DittoConnectivityConfig.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/MessageRateLimiter.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/backoff/DuplicationRetryTimeoutStrategyTest.java (diff)
The file was addedservices/connectivity/common/src/test/java/org/eclipse/ditto/services/connectivity/config/DefaultClientConfigTest.java
The file was addedservices/connectivity/common/src/test/resources/kafka-test.conf
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultRateConfig.java
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/backoff/DefaultBackOffConfigTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/MessageRateLimiterBehavior.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultConnectionConfig.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/metrics/ConnectivityCounterRegistry.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultAmqp091Config.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/Amqp091Config.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/ProducerPropertiesFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/ConnectionLoggerRegistry.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/ConnectionLoggerRegistryTest.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultBackOffConfig.java
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/MqttConfig.java
The file was addedservices/connectivity/common/src/test/java/org/eclipse/ditto/services/connectivity/config/DefaultConnectionConfigTest.java
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/package-info.java
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultKafkaConfig.java
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/BackOffConfig.java
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DittoConnectivityConfigProvider.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/DefaultKafkaConnectionFactory.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/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/RawMessageMapperTest.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/MonitoringCounterConfig.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseConsumerActor.java (diff)
The file was removedservices/connectivity/messaging/src/test/resources/backoff-test.conf
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActorTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/ImplicitThingCreationMessageMapper.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultAmqp10Config.java
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/javascript/package-info.java
The file was removedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/MappingConfig.java
The file was addedservices/connectivity/common/src/test/resources/client-test.conf
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigProvider.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultRateConfig.java
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/backoff/BackOffActorTest.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/starter/src/main/java/org/eclipse/ditto/services/connectivity/ConnectivityService.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/Amqp10Config.java
The file was addedservices/connectivity/common/src/test/resources/mapping-test.conf
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/ConnectionConfig.java
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ClientConfig.java
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultClientConfig.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/KafkaConfig.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DittoConnectivityConfig.java
The file was addedservices/connectivity/common/src/test/resources/monitoring-test.conf
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultAmqp10Config.java
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/DroppingMessageMapper.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/mapping/MappingConfig.java
The file was addedservices/connectivity/common/src/test/resources/reconnection-test.conf
The file was removedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultClientConfigTest.java
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigProviderFactory.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/MonitoringLoggerConfig.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/MonitoringConfig.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ReconnectActor.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultHttpPushConfig.java
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/MonitoringLoggerConfig.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActor.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/mapping/DefaultMapperLimitsConfig.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/DefaultConnectionMonitorRegistry.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/backoff/DefaultTimeoutConfig.java
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/HttpPushConfig.java
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/mapping/package-info.java
The file was removedservices/connectivity/messaging/src/test/resources/reconnection-test.conf
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/FaultyMessageMapper.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultAmqp091Config.java
The file was removedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/javascript/DefaultJavaScriptConfig.java
The file was modifiedbom/pom.xml (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/TimeoutConfig.java
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/javascript/benchmark/JavaScriptMessageMapperRhinoBenchmarkTest.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfig.java
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultReconnectConfig.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushFactory.java (diff)
The file was addedservices/connectivity/common/src/test/java/org/eclipse/ditto/services/connectivity/config/DefaultReconnectConfigTest.java
Commit d66858d3feb3b51afba920c7f20fc0412c8f7544 by Dominik Guggemos
use ConnectivityConfigProvider in ConnectionPersistenceActor and AmqpConsumerActor

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/utils/protocol/src/main/java/org/eclipse/ditto/services/utils/protocol/ProtocolAdapterProvider.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/HostValidator.java (diff)
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigProviderFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActor.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/ConnectivityConfigModifiedBehavior.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/MessageRateLimiter.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/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigProvider.java (diff)
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DittoConnectivityConfigProvider.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java (diff)
Commit 6dab750d6e9bd452873cc541e2449ebd05565532 by Dominik Guggemos
fix missing license header

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedservices/connectivity/common/pom.xml (diff)
Commit 715bd3ed4fbb8146b77d7c1fede16bfe3dce4e71 by Dominik Guggemos
add missing semicolon

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActor.java (diff)
Commit 1c18327c846c9695f22d6f6b79a9af2c31e3d137 by Dominik Guggemos
fix tests, clean up ConnectionValidator

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedservices/connectivity/messaging/pom.xml (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/common/pom.xml (diff)
The file was modifiedbom/pom.xml (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java (diff)
Commit e5a4096bbd94d1603bba3ffd2d58a45c2b676f4a by Dominik Guggemos
add javadoc, add more unit tests

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigProvider.java (diff)
The file was modifiedservices/connectivity/common/pom.xml (diff)
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigBuildable.java (diff)
The file was removedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/ConnectivityConfigModifiedBehavior.java
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigProviderFactory.java (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigUnavailableException.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java (diff)
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DittoConnectivityConfigProvider.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActor.java (diff)
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigEvent.java (diff)
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was addedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigModifiedBehavior.java
Commit 789208a3867032c1172542e7520ede36a3a63fc1 by Dominik Guggemos
add required property to test config, fix tests

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/resources/test.conf (diff)
The file was modifiedservices/connectivity/starter/src/test/java/org/eclipse/ditto/services/connectivity/ConnectivityServiceGlobalErrorRegistryTest.java (diff)
Commit af3897548dd98e3be00e66ef30627b9d52514980 by Dominik Guggemos
use ditto default config in ConnectionPersistenceActor

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
Commit bead292fd4a2dd9b49161c70c1539e71eae64819 by Stefan Maute
removed duplicate copyright header;
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigProviderFactory.java (diff)
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigProvider.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActor.java (diff)
Commit fb5a96b105d18e67e8ba7d4740bce5875e79d9bd by Dominik Guggemos
simplify ConnectivityConfigProvider, revert ssome previous changes

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidator.java (diff)
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigProvider.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/HostValidatorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/HostValidator.java (diff)
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigProviderFactory.java (diff)
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DittoConnectivityConfigProvider.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java (diff)
Commit 9438c01bfd90ddf2816be14cafb6bb257c6cbf32 by vadim.guenther
Extend validation for number of mapped messages

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/connectivity/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/DefaultMessageMapperFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/AbstractProtocolValidator.java (diff)
Commit 73624807ea1a2341a3618b2545c73c202bb8eb6f by Dominik Guggemos
add timers to AbstractActorWithLock

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/AbstractActorWithLock.java (diff)
Commit abc02fc8b5757515334d03c01f532eebe79f1608 by Dominik Guggemos
fix several equals methods, remove empty MonitoringCounterConfig

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultConnectionConfig.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/metrics/ConnectivityCounterRegistry.java (diff)
The file was modifiedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/operations/AbstractPersistenceOperationsActor.java (diff)
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/config/DefaultMetricsReporterConfig.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/metrics/ConnectivityCounterRegistryTest.java (diff)
The file was removedservices/connectivity/common/src/test/java/org/eclipse/ditto/services/connectivity/config/DefaultMonitoringConfigTest.java
The file was removedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/MonitoringCounterConfig.java
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/MonitoringConfig.java (diff)
The file was removedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultMonitoringCounterConfig.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/DefaultConnectionMonitorRegistry.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/TestConstants.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/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultMonitoringConfig.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/ConnectionLoggerRegistry.java (diff)
Commit 92b428863e071a2a2d517d053520b7eea8f4a0db by Dominik Guggemos
fix unit test

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/ConnectionLoggerRegistryTest.java (diff)
Commit b3fcc4cd14bee9c756de7693e341dc9e73251931 by Dominik Guggemos
handle connectivity config changes in BaseClientActor by creating a new MessageMappingProcessor

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigModifiedBehavior.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/BaseClientActor.java (diff)
Commit 1d019029ff93eb59c00db1c2626fa1f306aa76e8 by Dominik Guggemos
remove debug output

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedsignals/commands/connectivity/src/test/java/org/eclipse/ditto/signals/commands/connectivity/exceptions/ConnectionFailedExceptionTest.java (diff)
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultConnectionConfig.java (diff)
Commit aaecaf68ceb405256a4323e4703c2b4af414a5bf by Stefan Maute
update base image version and add copyright header;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modifiedservices/dockerfile-snapshot (diff)
The file was modifiedservices/dockerfile-release (diff)
Commit 89cd82eeb98d121c66332b684b615fa30e64e130 by vadim.guenther
Fix unit test

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
Commit a0ba5d68901befbddc4f51cc5c19d0fb1fd73897 by vadim.guenther
Fix tests

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java (diff)
Commit 6f97724b7388aa70984cff1e0ba2cecf5bb4c2a5 by Dominik Guggemos
Transform ThingsConnectivityConfigProvider into an extension to make it available when actor system is started e.g. when shard rebalancing happens. Remove ThingsConnectivityConfigProviderActor because it is not available that early on startup and resulted in ask timeouts.

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DittoConnectivityConfigProvider.java (diff)
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigModifiedBehavior.java (diff)
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigProvider.java (diff)
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigProviderFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java (diff)
The file was removedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigEvent.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidator.java (diff)
The file was removedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectivityConfigBuildable.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
Commit 5c51f05579990e79a5f30b0512ea5f31f5f76c98 by Dominik Guggemos
fix unit test, remove debug output

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/ConnectionPersistenceActorRecoveryTest.java (diff)
Commit 6ead04465fae8103f6f447af504a547de481368e by Dominik Guggemos
more fine-grained handling of changes to mapping processor config in BaseClientActor

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java (diff)
Commit 0cb79ad10daa5c48bececd3401772e053a34c074 by Dominik Guggemos
set ditto headers for mapping exception

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedservices/connectivity/mapping/src/test/java/org/eclipse/ditto/services/connectivity/mapping/WrappingMessageMapperTest.java (diff)
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/WrappingMessageMapper.java (diff)
Commit f494f1e02a2731f20c9e83520d98cf7e66e8492e by Dominik Guggemos
fix initialization of OutboundMappingProcessor

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
Commit a3416efaa05a843fbb5d1ecde1a7a1a7eacf40ea by Stefan Maute
change parameter type to int because maxNumber of source and target can not be a double;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidator.java (diff)
Commit 5ed88656089f0819c5f3d2ad4249e8a0cf11c79d by vadim.guenther
Fix test error

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java (diff)
Commit 5250f4fa23b2b19336f903ac948898592dc62c03 by Stefan Maute
update test case for JsonObjectMergerTest;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modifiedjson/src/test/java/org/eclipse/ditto/json/JsonObjectMergerTest.java (diff)
Commit 2f810f83b632962a21bbac999b6ee87da5dbc947 by vadim.guenther
Exclude Javadoc generation for services.utils.akka.actors package to get mixed Scala/Java build to work.

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was addedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/actors/AbstractActorWithLock.java
The file was modifiedservices/utils/akka/pom.xml (diff)
The file was removedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/AbstractActorWithLock.java
Commit 19239b0b0321f257171f0032619ac29afda57c5d by vadim.guenther
Adjust javadoc comments

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultMonitoringLoggerConfig.java (diff)
Commit 691b9d52b63cacbc1ecd080b182e57c3074533a1 by Stefan Maute
add since annotation to new method in JsonFactory
The file was modifiedjson/src/main/java/org/eclipse/ditto/json/JsonFactory.java (diff)