Skip to content

Changes

Summary

  1. #1081 add conditioned thing templates list to implicit mapper (details)
  2. #1081 add exists to filter functions (details)
  3. #1081 Add priority to mappers (details)
  4. #1081: remove requirement of passing knowledge about "exists" function in PipelineFunctionFilter (details)
  5. #1081: add optional parameters 'true' and 'false' to the 'exists' pipeline filter (details)
  6. Revert "#1081 add conditioned thing templates list to implicit mapper" (details)
  7. [#1081] minor fixes. (details)
  8. [#1081] Make connection context available for message mappers. (details)
  9. [#1081] Replace ConnectivityConfigProvider by ConnectionContextProvider. (details)
  10. [#1081] Make ConnectionContextProvider asynchronous. (details)
  11. [#1081] Allow customization of expression resolver in ImplicitThingCreationMessageMapper. (details)
  12. [#1081] Fix client actors not reacting to connectivity config updates. (details)
  13. [#1081] update connection config in connection persistence actor. (details)
  14. [#1081] make query parser asynchronous. (details)
  15. [#1081]: add unit test for DittoConnectionContext (details)
  16. [#1081] Add fail safe for connectivity config change registration. (details)
  17. [#1081] Make Ditto headers serializable & add them as an extra parameter for client actors. (details)
  18. [#1081]: add clarifying comment why deleteStrategy is get during runtime (details)
  19. bump qpid-jms-client version to 1.0.0; (details)
  20. [#1081] Remove blocking wait in JWT authentication. (details)
  21. removed max-bulk-size from UpdaterConfig; (details)
  22. removed test for max-bulk-size from DefaultUpdaterConfigTest; (details)
  23. add more check methods to ScopedConfig which check the values read from the config file and throws DittoConfigError when the value is not in the expected range; (details)
  24. rename methods and fix result check; (details)
  25. adapt snapshot-test.conf to fix DefaultSnapshotConfigTest; (details)
  26. fix DefaultSnapshotConfigTest; (details)
  27. allow EVENT_LOOP_THREADS to be 0; (details)
  28. relaxed some checks for reading config values; (details)
  29. add implicitStandanloneThingCreation mapper description (details)
  30. update link to Eclipse Vorto (details)
  31. [#1081] relax filter condition for mappers. (details)
  32. fixed getting workers config in DefaultTunnelConfig (workers can be 0); (details)
  33. [#1081]: add examples for the new exists filter for placeholders (details)
  34. switch to getNonNegativeDurationOrThrow for writeInterval in DefaultStreamConfig; (details)
  35. threshold for Snapshot only have to be positive; (details)
  36. fix evicting queue growing unbounded under high load (details)
  37. change instantiation of DefaultPersistenceCleanupConfig when updating; (details)
  38. [#1081] fix copyright year (details)
  39. update Netty to 4.1.65.Final (details)
  40. #558 provide some basic Grafana dashboards as starting point in monitoring Eclipse Ditto (details)
  41. fixed missing OSGi import of "org.atteo.classindex" in ditto-base-model (details)
  42. review: made some configs "non 0"-able where reasonable (details)
Commit 1d0997d35f6426fae0f998e165f8fee85ef9df21 by Vadim Günther
#1081 add conditioned thing templates list to implicit mapper

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/ImplicitThingCreationMessageMapperTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/mapping/ImplicitThingCreationMessageMapper.java (diff)
Commit d0616a78d53ef35bf08130167c79a977eeb74ea8 by Vadim Günther
#1081 add exists to filter functions

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was addedinternal/models/placeholders/src/main/java/org/eclipse/ditto/internal/models/placeholders/filter/ExistsFunction.java
The file was modified internal/models/placeholders/src/main/java/org/eclipse/ditto/internal/models/placeholders/PipelineFunctionParameterResolverFactory.java (diff)
The file was modified internal/models/placeholders/src/test/java/org/eclipse/ditto/internal/models/placeholders/PipelineFunctionFilterTest.java (diff)
The file was modified internal/models/placeholders/src/main/java/org/eclipse/ditto/internal/models/placeholders/PipelineFunctionFilter.java (diff)
The file was modified internal/models/placeholders/src/main/java/org/eclipse/ditto/internal/models/placeholders/filter/FilterFunctions.java (diff)
Commit bdefeb581396dae6e2d0f55d36ab5fc9f249c6fe by Florian Fendt
#1081 Add priority to mappers

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/mapping/PayloadMapper.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/mapping/ImplicitThingCreationMessageMapper.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/mapping/DefaultMessageMapperFactory.java (diff)
Commit a44e91f9ef559886e6e98dd504861270d4c50e88 by Florian Fendt
#1081: remove requirement of passing knowledge about "exists" function in PipelineFunctionFilter

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified internal/models/placeholders/src/main/java/org/eclipse/ditto/internal/models/placeholders/filter/FilterFunction.java (diff)
The file was modified internal/models/placeholders/src/test/java/org/eclipse/ditto/internal/models/placeholders/PipelineFunctionParameterResolverFactoryTest.java (diff)
The file was modified internal/models/placeholders/src/main/java/org/eclipse/ditto/internal/models/placeholders/PipelineFunctionFilter.java (diff)
The file was modified internal/models/placeholders/src/main/java/org/eclipse/ditto/internal/models/placeholders/PipelineFunctionParameterResolverFactory.java (diff)
Commit 9b72507065568cb44485010f1121584f196d2432 by Florian Fendt
#1081: add optional parameters 'true' and 'false' to the 'exists' pipeline filter

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified internal/models/placeholders/src/main/java/org/eclipse/ditto/internal/models/placeholders/filter/ExistsFunction.java (diff)
The file was modified internal/models/placeholders/src/test/java/org/eclipse/ditto/internal/models/placeholders/PipelineFunctionFilterTest.java (diff)
Commit 308931c9e1326410249a7477f0289c21c3a1ecf3 by Florian Fendt
Revert "#1081 add conditioned thing templates list to implicit mapper"

This reverts commit 1d0997d3

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/mapping/ImplicitThingCreationMessageMapper.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/ImplicitThingCreationMessageMapperTest.java (diff)
Commit e7c5944643ce1bf86a5ec153d3e552c59495e9b5 by Yufei Cai
[#1081] minor fixes.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/mapping/DefaultMessageMapperFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpClientActor.java (diff)
Commit b131186aacc178a82e7019788d8c0afbb5de212b by Yufei Cai
[#1081] Make connection context available for message mappers.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/mapping/DittoConnectionContext.java
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/NormalizedMessageMapperTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/javascript/benchmark/MapToDittoProtocolScenario.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/InboundMappingProcessorTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/DefaultMessageMapperFactoryTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/javascript/JavaScriptMessageMapperRhinoTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/mapping/WrappingMessageMapper.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/InboundMappingProcessor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/AbstractConsumerActorTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/InboundMappingProcessorActorTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/OutboundDispatchingActorTest.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/mapping/ConnectionContext.java
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/javascript/benchmark/SimpleMapTextPayloadToDitto.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/OutboundMappingProcessor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/ConnectionStatusMessageMapperTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/javascript/benchmark/Test3FormatJsonPayloadToDitto.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/javascript/JavaScriptMessageMapperRhinoSandboxingTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/RawMessageMapperTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/OutboundMappingProcessorActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/mapping/MessageMapper.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpConsumerActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/OutboundMappingSettings.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/mapping/RawMessageMapper.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/AddHeaderMessageMapper.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/mapping/AbstractMessageMapper.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/javascript/benchmark/Test1DecodeBinaryPayloadToDitto.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/WrappingMessageMapperTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/javascript/benchmark/Test2ParseJsonPayloadToDitto.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/test/MockMapper.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/validation/AbstractProtocolValidator.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/javascript/benchmark/Test5DecodeBinaryToDitto.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/ThrowingMapper.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/mapping/DefaultMessageMapperFactory.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/ImplicitThingCreationMessageMapperTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/javascript/benchmark/Test4ConstructJsonPayloadToDitto.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/AbstractMessageMappingProcessorActorTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/OutboundMappingProcessorTest.java (diff)
Commit cb0de868c124208870b7589ef812232dbb431adc by Yufei Cai
[#1081] Replace ConnectivityConfigProvider by ConnectionContextProvider.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DittoConnectionContextProvider.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpValidator.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPushValidator.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/validation/AbstractProtocolValidator.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectivityConfigProviderFailedException.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/Mqtt3ValidatorTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/HiveMqtt3ClientActorTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/validation/ConnectionValidatorTest.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectionContextProvider.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectivityConfigProviderMissingException.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/HiveMqtt5ClientActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectivityConfigModifiedBehavior.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectivityConfigProviderFactory.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/Mqtt5Validator.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaValidator.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/rabbitmq/RabbitMQValidator.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/rabbitmq/RabbitMQValidatorTest.java (diff)
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectivityConfigProvider.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/AbstractMqttValidatorTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaValidatorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectivityConfig.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPushValidatorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/validation/ConnectionValidator.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/Mqtt3Validator.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/AbstractMqttClientActorTest.java (diff)
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DittoConnectivityConfigProvider.java
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/MqttServerRule.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/Mqtt5ValidatorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpConsumerActor.java (diff)
Commit bf548288797fbe3ddb0fdc12a4c95d750b9d2b11 by Yufei Cai
[#1081] Make ConnectionContextProvider asynchronous.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectivityConfigProviderMissingException.java
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpConsumerActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpConsumerActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/mapping/ConnectionContext.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectionContextProviderFactory.java
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/amqp/JmsConnectionHandlingActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/ConsumerData.java (diff)
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectivityConfigProviderFailedException.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/JMSConnectionHandlingActor.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectionContextProviderMissingException.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectionContextProvider.java (diff)
The file was removedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectivityConfigProviderFactory.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectivityConfigModifiedBehavior.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/mapping/DittoConnectionContext.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectionContextProviderFailedException.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DittoConnectionContextProvider.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/AbstractMqttClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/rabbitmq/RabbitMQClientActor.java (diff)
Commit f634bba5df50bbd3bae9648c03d36d828683b368 by Yufei Cai
[#1081] Allow customization of expression resolver in ImplicitThingCreationMessageMapper.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/mapping/ImplicitThingCreationMessageMapper.java (diff)
Commit 8a5f67400f30cfca2abfc2059c60a7ed07e6f4f3 by Yufei Cai
[#1081] Fix client actors not reacting to connectivity config updates.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpConsumerActor.java (diff)
Commit bd36c1058b17d379eea64b36759b6c25dce63677 by Yufei Cai
[#1081] update connection config in connection persistence actor.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectionContextProvider.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/validation/ConnectionValidator.java (diff)
The file was modified internal/utils/persistent-actors/src/main/java/org/eclipse/ditto/internal/utils/persistentactors/AbstractShardedPersistenceActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DittoConnectionContextProvider.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectivityConfigModifiedBehavior.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/persistence/strategies/commands/ConnectionCreatedStrategies.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/persistence/strategies/commands/ConnectionUninitializedStrategies.java
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/persistence/strategies/commands/ConnectivityCommandStrategies.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/persistence/strategies/commands/ConnectionDeletedStrategies.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/validation/ConnectionValidatorTest.java (diff)
Commit 20423895525b96b1f2b05a4b01992c8bd31064f8 by Yufei Cai
[#1081] make query parser asynchronous.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/starter/actors/SearchActor.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/query/validation/QueryCriteriaValidator.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/query/validation/DefaultQueryCriteriaValidator.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/query/QueryParser.java (diff)
Commit fa7a601f1a3ce385338c2c0b88fce1e72f3441f1 by Florian Fendt
[#1081]: add unit test for DittoConnectionContext

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectivityConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/mapping/ConnectionContext.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/validation/AbstractProtocolValidator.java (diff)
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/mapping/DittoConnectionContextTest.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectionContextProvider.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/mapping/DittoConnectionContext.java (diff)
Commit 672c3ff90a2b4d224ba7dffc9dac5ada47aeaa32 by Yufei Cai
[#1081] Add fail safe for connectivity config change registration.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectionContextProvider.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DittoConnectionContextProvider.java (diff)
Commit 6a5a52d482ea3ef4089250eeccba9a3e60f44952 by Yufei Cai
[#1081] Make Ditto headers serializable & add them as an extra parameter for client actors.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/AbstractMqttClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/FaultyClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectivityConfigModifiedBehavior.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/HiveMqtt5ClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/DefaultClientActorPropsFactory.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/DefaultClientActorPropsFactoryTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPushClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/rabbitmq/RabbitMQClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/HiveMqtt3ClientActor.java (diff)
The file was modified base/model/src/main/java/org/eclipse/ditto/base/model/headers/DittoHeaders.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPushClientActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/validation/DittoConnectivityCommandValidator.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/MockClientActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/HiveMqtt3ClientActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/ClientActorPropsFactory.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/AbstractBaseClientActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectionContextProvider.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpConsumerActor.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/HiveMqtt5ClientActorTest.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/ErrorHandlingActorTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpClientActor.java (diff)
Commit dc907f9df42a6842bea933da8244af117199554d by Florian Fendt
[#1081]: add clarifying comment why deleteStrategy is get during runtime

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified internal/utils/persistent-actors/src/main/java/org/eclipse/ditto/internal/utils/persistentactors/AbstractShardedPersistenceActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectionContextProvider.java (diff)
Commit b2dc165c359896743cdc4713473709b65413b0bd by Stefan Maute
bump qpid-jms-client version to 1.0.0;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified bom/pom.xml (diff)
Commit 22b9003c09346c06544b70ca3eee0385319e2f77 by Yufei Cai
[#1081] Remove blocking wait in JWT authentication.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified gateway/service/src/test/java/org/eclipse/ditto/gateway/service/security/authentication/jwt/DefaultJwtAuthenticationResultProviderTest.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/security/authentication/jwt/JwtAuthenticationResultProvider.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/endpoints/utils/GatewayCachingSignalEnrichmentProvider.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/security/authentication/TimeMeasuringAuthenticationProvider.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/endpoints/utils/GatewaySignalEnrichmentProvider.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/endpoints/routes/websocket/WebSocketRoute.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/security/authentication/jwt/JwtAuthenticationProvider.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/security/authentication/jwt/DefaultJwtAuthenticationResultProvider.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/streaming/actors/StreamingSessionActor.java (diff)
The file was modified gateway/service/src/test/java/org/eclipse/ditto/gateway/service/security/authentication/jwt/AbstractJwtAuthenticationProviderTest.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/endpoints/utils/GatewayByRoundTripSignalEnrichmentProvider.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/endpoints/routes/sse/ThingsSseRouteBuilder.java (diff)
The file was modified gateway/service/src/test/java/org/eclipse/ditto/gateway/service/streaming/actors/StreamingSessionActorTest.java (diff)
Commit 17f64fa25d70de23bd8ab6c84a24783951fc98ce by Stefan Maute
removed max-bulk-size from UpdaterConfig;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified internal/utils/config/src/main/java/org/eclipse/ditto/internal/utils/config/ScopedConfig.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/common/config/DefaultUpdaterConfig.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/common/config/UpdaterConfig.java (diff)
Commit 98cf798ea728f1150bc4385109c110c375bf35df by Stefan Maute
removed test for max-bulk-size from DefaultUpdaterConfigTest;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified thingsearch/service/src/test/java/org/eclipse/ditto/thingsearch/service/common/config/DefaultUpdaterConfigTest.java (diff)
Commit 9bcf2b6abd0e55f5a53bd65dab67552e54fa990e by Stefan Maute
add more check methods to ScopedConfig which check the values read from the config file and throws DittoConfigError when the value is not in the expected range;
use check methods in DefaultConfig classes to prevent miss configuration of Ditto services;
add missing config values;
remove maxFailures from things-search.conf (not used anymore);

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/util/config/endpoints/DefaultClaimMessageConfig.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/util/config/streaming/DefaultWebsocketConfig.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/common/DefaultPersistenceCleanupConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultHttpPushConfig.java (diff)
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/config/DefaultSnapshotConfig.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/util/config/security/DefaultDevOpsConfig.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/common/DefaultEnforcementConfig.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/common/config/DefaultStreamCacheConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/javascript/DefaultJavaScriptConfig.java (diff)
The file was modified internal/utils/health/src/main/java/org/eclipse/ditto/internal/utils/health/config/DefaultBasicHealthCheckConfig.java (diff)
The file was modified base/service/src/main/java/org/eclipse/ditto/base/service/config/DefaultThrottlingConfig.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/util/config/streaming/DefaultGatewaySignalEnrichmentConfig.java (diff)
The file was modified internal/utils/metrics/src/main/java/org/eclipse/ditto/internal/utils/metrics/config/DefaultMetricsConfig.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/common/config/DittoSearchConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaProducerConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultConnectionConfig.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/common/DefaultCachesConfig.java (diff)
The file was modified base/service/src/main/java/org/eclipse/ditto/base/service/config/supervision/DefaultSupervisorConfig.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/util/config/health/DefaultHealthCheckConfig.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/util/config/security/DefaultOAuthConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultConnectionIdsRetrievalConfig.java (diff)
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/config/DefaultCircuitBreakerConfig.java (diff)
The file was modified internal/utils/ddata/src/main/java/org/eclipse/ditto/internal/utils/ddata/DefaultDistributedDataConfig.java (diff)
The file was modified internal/models/signalenrichment/src/main/java/org/eclipse/ditto/internal/models/signalenrichment/DefaultSignalEnrichmentConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultMonitoringLoggerConfig.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/updater/actors/BackgroundSyncActor.java (diff)
The file was modified thingsearch/service/src/main/resources/things-search.conf (diff)
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/operations/DefaultPersistenceOperationsConfig.java (diff)
The file was modified internal/utils/cluster/src/main/java/org/eclipse/ditto/internal/utils/cluster/config/DefaultClusterConfig.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/common/PersistenceCleanupConfig.java (diff)
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/config/DefaultTimeoutConfig.java (diff)
The file was modified policies/service/src/main/java/org/eclipse/ditto/policies/service/common/config/DefaultPolicyConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaConsumerConfig.java (diff)
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/config/DefaultConnectionPoolConfig.java (diff)
The file was modified internal/utils/config/src/main/java/org/eclipse/ditto/internal/utils/config/ScopedConfig.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/common/PersistenceIdsConfig.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/util/config/endpoints/DefaultCommandConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/mapping/DefaultMappingConfig.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/common/DefaultCreditDecisionConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/mapping/MapperLimitsConfig.java (diff)
The file was modified internal/utils/persistent-actors/src/main/java/org/eclipse/ditto/internal/utils/persistentactors/config/DefaultRateConfig.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/common/DittoConciergeConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultBackOffConfig.java (diff)
The file was modified internal/utils/persistence/src/test/resources/snapshot-test.conf (diff)
The file was modified concierge/service/src/main/resources/concierge.conf (diff)
The file was modified internal/utils/persistent-actors/src/main/java/org/eclipse/ditto/internal/utils/persistentactors/config/DefaultPingConfig.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/common/DefaultThingsAggregatorConfig.java (diff)
The file was modified internal/utils/health/src/main/java/org/eclipse/ditto/internal/utils/health/config/DefaultPersistenceConfig.java (diff)
The file was modified base/service/src/main/java/org/eclipse/ditto/base/service/config/limits/DefaultLimitsConfig.java (diff)
The file was modified connectivity/service/src/main/resources/connectivity.conf (diff)
The file was modified internal/utils/health/src/main/java/org/eclipse/ditto/internal/utils/health/config/DefaultHealthCheckConfig.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/util/config/endpoints/DefaultMessageConfig.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/util/config/streaming/DefaultStreamingConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultAmqp091Config.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/common/config/DefaultUpdaterConfig.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/util/config/security/DefaultCachesConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultAmqp10Config.java (diff)
The file was modified internal/utils/health/src/main/java/org/eclipse/ditto/internal/utils/health/AbstractBackgroundStreamingActorWithConfigWithStatusReport.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/common/config/DefaultStreamStageConfig.java (diff)
The file was modified internal/utils/config/src/test/resources/test.conf (diff)
The file was modified internal/models/acks/src/main/java/org/eclipse/ditto/internal/models/acks/config/DefaultAcknowledgementConfig.java (diff)
The file was modified base/service/src/main/java/org/eclipse/ditto/base/service/config/http/DefaultHttpConfig.java (diff)
The file was modified internal/utils/ddata/src/main/java/org/eclipse/ditto/internal/utils/ddata/DefaultAkkaReplicatorConfig.java (diff)
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/config/DefaultMongoDbConfig.java (diff)
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/config/DefaultOptionsConfig.java (diff)
The file was modified internal/utils/health/src/main/java/org/eclipse/ditto/internal/utils/health/config/DefaultMetricsReporterConfig.java (diff)
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/config/DefaultTagsConfig.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/common/DefaultPersistenceIdsConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultTimeoutConfig.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/util/config/endpoints/DefaultPublicHealthConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultClientConfig.java (diff)
The file was modified internal/utils/config/src/main/java/org/eclipse/ditto/internal/utils/config/ConfigWithFallback.java (diff)
The file was modified base/service/src/main/java/org/eclipse/ditto/base/service/config/supervision/DefaultExponentialBackOffConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/mapping/DefaultMapperLimitsConfig.java (diff)
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/config/DefaultActivityCheckConfig.java (diff)
The file was modified internal/utils/cache/src/main/java/org/eclipse/ditto/internal/utils/cache/config/DefaultCacheConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultMqttConfig.java (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/proxy/config/DefaultStatisticsConfig.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/common/config/DefaultPersistenceStreamConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultTunnelConfig.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/common/config/DefaultStreamConfig.java (diff)
Commit 2ba33f6cd0f1197d5710c4f4adf9b3380e5ea720 by Stefan Maute
rename methods and fix result check;
adapt test config to fix failing tests;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/mapping/DefaultMappingConfig.java (diff)
The file was modified internal/utils/config/src/main/java/org/eclipse/ditto/internal/utils/config/ScopedConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultConnectionConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultMqttConfig.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/common/DefaultPersistenceIdsConfig.java (diff)
The file was modified base/service/src/main/java/org/eclipse/ditto/base/service/config/limits/DefaultLimitsConfig.java (diff)
The file was modified base/service/src/main/java/org/eclipse/ditto/base/service/config/supervision/DefaultExponentialBackOffConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaProducerConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultMonitoringLoggerConfig.java (diff)
The file was modified internal/models/acks/src/main/java/org/eclipse/ditto/internal/models/acks/config/DefaultAcknowledgementConfig.java (diff)
The file was modified internal/utils/persistence/src/test/resources/activity-check-test.conf (diff)
The file was modified gateway/service/src/main/java/org/eclipse/ditto/gateway/service/util/config/streaming/DefaultWebsocketConfig.java (diff)
The file was modified internal/utils/persistence/src/test/java/org/eclipse/ditto/internal/utils/persistence/mongo/config/DefaultActivityCheckConfigTest.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/common/config/DefaultStreamConfig.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/common/DefaultThingsAggregatorConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultConnectionIdsRetrievalConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultAmqp10Config.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/mapping/DefaultMapperLimitsConfig.java (diff)
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/config/DefaultConnectionPoolConfig.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/common/DefaultCreditDecisionConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/javascript/DefaultJavaScriptConfig.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/common/DefaultPersistenceCleanupConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultHttpPushConfig.java (diff)
Commit 7910f936986356ef3556c6da218b31c1678351fe by Stefan Maute
adapt snapshot-test.conf to fix DefaultSnapshotConfigTest;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified internal/utils/persistence/src/test/resources/snapshot-test.conf (diff)
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/config/DefaultSnapshotConfig.java (diff)
Commit 9badee286e22a47508f3b98a30d93b1fbf9177f5 by Stefan Maute
fix DefaultSnapshotConfigTest;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified internal/utils/persistence/src/test/java/org/eclipse/ditto/internal/utils/persistence/mongo/config/DefaultSnapshotConfigTest.java (diff)
Commit 15431ea8da56704ade62f4f882e803fbc6841673 by Stefan Maute
allow EVENT_LOOP_THREADS to be 0;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultMqttConfig.java (diff)
Commit fc7f7a51e94e3412e938879d453d816fbc520dd5 by Stefan Maute
relaxed some checks for reading config values;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified policies/service/src/test/java/org/eclipse/ditto/policies/service/starter/PoliciesRootActorTest.java (diff)
The file was modified base/service/src/main/java/org/eclipse/ditto/base/service/config/http/DefaultHttpConfig.java (diff)
The file was modified internal/utils/metrics/src/main/java/org/eclipse/ditto/internal/utils/metrics/config/DefaultMetricsConfig.java (diff)
The file was modified internal/utils/config/src/main/java/org/eclipse/ditto/internal/utils/config/DefaultScopedConfig.java (diff)
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/config/DefaultActivityCheckConfig.java (diff)
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/config/DefaultSnapshotConfig.java (diff)
The file was modified policies/service/src/main/java/org/eclipse/ditto/policies/service/common/config/DefaultPolicyConfig.java (diff)
Commit d37efa3c05e45b661d0ab47857c51a929c80dc09 by marianne.klein
add implicitStandanloneThingCreation mapper description

Signed-off-by: marianne-klein <marianne.klein@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/connectivity-mapping.md (diff)
Commit b99bc674e63749b26e14c1a68f55aad1e2685b8c by marianne.klein
update link to Eclipse Vorto

Signed-off-by: marianne-klein <marianne.klein@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/connectivity-mapping.md (diff)
Commit d4e7296850252cf2bc45588c8edee7f4daf1d341 by Yufei Cai
[#1081] relax filter condition for mappers.

Now an incoming condition filter passes if it is resolvable,
not only when it resolves to 'true'.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/AbstractMappingProcessor.java (diff)
Commit 8b8a2274da63f721f8ec092785e20b3905a24ac2 by Stefan Maute
fixed getting workers config in DefaultTunnelConfig (workers can be 0);
add correct config value to search test.conf to get ThingUpdaterTest running;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/updater/actors/ThingUpdater.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/updater/actors/SearchUpdaterRootActor.java (diff)
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/starter/actors/SearchRootActor.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultTunnelConfig.java (diff)
The file was modified thingsearch/service/src/test/resources/updater-test.conf (diff)
The file was modified thingsearch/service/src/test/java/org/eclipse/ditto/thingsearch/service/updater/actors/ThingUpdaterTest.java (diff)
The file was modified thingsearch/service/src/test/resources/test.conf (diff)
The file was modified internal/utils/config/src/main/java/org/eclipse/ditto/internal/utils/config/ScopedConfig.java (diff)
Commit 35aea02c74bd8225d0ab01337d47071d5d0c32cb by Florian Fendt
[#1081]: add examples for the new exists filter for placeholders

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified documentation/src/main/resources/pages/ditto/connectivity-mapping.md (diff)
The file was modified documentation/src/main/resources/pages/ditto/basic-placeholders.md (diff)
Commit a8ef5bd5cb265399ef929f769fdc56bfd0590db7 by Stefan Maute
switch to getNonNegativeDurationOrThrow for writeInterval in DefaultStreamConfig;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/common/config/DefaultStreamConfig.java (diff)
Commit db75cf4945411260149618b55c426e8dbc1b0980 by Stefan Maute
threshold for Snapshot only have to be positive;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/config/DefaultSnapshotConfig.java (diff)
The file was modified internal/utils/persistence/src/test/java/org/eclipse/ditto/internal/utils/persistence/mongo/config/DefaultSnapshotConfigTest.java (diff)
The file was modified internal/utils/config/src/test/resources/test.conf (diff)
The file was modified internal/utils/persistence/src/test/resources/snapshot-test.conf (diff)
Commit 183f1d81b395f1a16d62092568aab104e0b475a9 by Dominik Guggemos
fix evicting queue growing unbounded under high load

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/monitoring/logs/DefaultEvictingQueue.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/monitoring/logs/DefaultEvictingQueueTest.java (diff)
Commit 48a1eb4f1b726d62b711739258c4c67b3e0ea89f by Stefan Maute
change instantiation of DefaultPersistenceCleanupConfig when updating;
check if cleanup isEnabled before scheduling the cleanup in EventSnapshotCleanupCoordinator;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/common/DefaultPersistenceCleanupConfig.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/common/PersistenceCleanupConfig.java (diff)
The file was modified internal/utils/health/src/main/java/org/eclipse/ditto/internal/utils/health/AbstractBackgroundStreamingActorWithConfigWithStatusReport.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultConnectionConfig.java (diff)
The file was modified internal/utils/akka/src/main/java/org/eclipse/ditto/internal/utils/akka/actors/ModifyConfigBehavior.java (diff)
The file was modified internal/utils/persistent-actors/src/main/java/org/eclipse/ditto/internal/utils/persistentactors/AbstractPersistentActorWithTimersAndCleanup.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/actors/cleanup/EventSnapshotCleanupCoordinator.java (diff)
Commit 109d7606ee5b990d4d6f4adc3d60fe272df443a2 by Florian Fendt
[#1081] fix copyright year

Signed-off-by: Florian Fendt <Florian.Fendt@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/ConnectionContextProvider.java (diff)
Commit 114044d5a5603bbe82857b597e2c0e0d751e6e85 by Thomas Jaeckle
update Netty to 4.1.65.Final
* re-generated legal docs
* added more verbose reporting to EventSnapshotCleanupCoordinator

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified legal/3rd-party-dependencies/compile.txt (diff)
The file was modified legal/NOTICE-THIRD-PARTY.md (diff)
The file was modified bom/pom.xml (diff)
The file was modified legal/3rd-party-dependencies/test.txt (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/actors/cleanup/EventSnapshotCleanupCoordinator.java (diff)
The file was modified legal/3rd-party-dependencies/runtime.txt (diff)
Commit cea6e8d3b50f695ebf038d956a964433ab77e930 by Thomas Jaeckle
#558 provide some basic Grafana dashboards as starting point in monitoring Eclipse Ditto

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified deployment/README.md (diff)
The file was addeddeployment/operations/grafana-dashboards/JVM_Metrics.json
The file was addeddeployment/operations/grafana-dashboards/External_Metrics.json
The file was addeddeployment/operations/grafana-dashboards/Hot_Entities.json
The file was modified documentation/src/main/resources/pages/ditto/installation-operating.md (diff)
The file was addeddeployment/operations/grafana-dashboards/Cluster_traffic.json
Commit bb8aa37920cc01f311d76ac05c25654e0233f512 by Thomas Jaeckle
fixed missing OSGi import of "org.atteo.classindex" in ditto-base-model
* removed from ditto-policies-model as not needed there

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified policies/model/pom.xml (diff)
The file was modified base/model/pom.xml (diff)
Commit 8d96b7c1ae20a8db6d7f44a78250f71bb3d0b32f by Thomas Jaeckle
review: made some configs "non 0"-able where reasonable
* removed unused MqttConfig.getSourceBufferSize()

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/mapping/DefaultMappingConfig.java (diff)
The file was modified internal/utils/config/src/main/java/org/eclipse/ditto/internal/utils/config/ScopedConfig.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/config/DefaultConnectionConfigTest.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/common/DefaultPersistenceCleanupConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultConnectionIdsRetrievalConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultHttpPushConfig.java (diff)
The file was modified concierge/service/src/main/java/org/eclipse/ditto/concierge/service/common/DefaultThingsAggregatorConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultMqttConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/javascript/DefaultJavaScriptConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/MqttConfig.java (diff)
The file was modified base/service/src/main/java/org/eclipse/ditto/base/service/config/supervision/DefaultExponentialBackOffConfig.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaProducerConfig.java (diff)