[Jenkins]Jenkins

SuccessChanges

Summary

  1. add isWeak flag to acknowledgement (details)
  2. Let WebSocketRoute issue a weak acknowledgement for all labels of a (details)
  3. Issue #852: change key type of declared ack labels DData from ActorRef to Address. (details)
  4. Issue #852: Fix ImmutableDittoHeadersTest. (details)
  5. Issue #852: Issue weak acknowledgements for rql filtered signals in connectivity (details)
  6. Issue #852: Document weak acknowledgements (details)
  7. Issue #852: Extract acks ddata as its own extension. (details)
  8. Issue #852: add means for other actors to receive local and remote ack declarations. (details)
  9. Issue #852: Send weak acks from publishers.end weak ACK (details)
  10. Issue #852: stabilize PubSubFactoryTest. (details)
  11. Issue #852: Send weak-acks from the subscriber side. (details)
  12. Issue #852: Review: rename header for weak ack; remove TODO. (details)
  13. Issue #852: Update header name for documentation of WACKs. Adjust wording. (details)
  14. fixed remaining loggers which were not threadsafe (details)
  15. fixed unit test (details)
  16. try to stabilize unit test (details)
  17. fixed shard statistics namespace grouping (was broken for thing names containing a ":") (details)
  18. Delay publishing of subscribe ack in order to ensure that subscribe is (details)
  19. Issue #852: change how connectivity issues weak acks. (details)
  20. Increase flapdoodle version to 3.0.0 (details)
  21. Issue #852: Fix 2 TODOs. (details)
  22. Issue #852: Remove waiting for heartbeats after subscription in PubSubFactoryTest. (details)
  23. Issue #852: Remove LogUtil. (details)
  24. Fix 1 TODO in OutboundMappingProcessorActor. (details)
  25. Issue #852: Explain in WACK that it can be issued for a variety of reasons. (details)
  26. Issue #852: add blog post about weak acks. (details)
  27. Issue #852: edit weak ack blogpost. (details)
  28. Issue #852: review of blogpost: (details)
  29. CR-8422 - add ditto-weak-ack header in table (details)
  30. Issue #852: remove existing "requested-acks" DittoHeader when creating an ImmutableAcknowledgement and an ImmutableAcknowledgements (details)
  31. Issue #852: fix javadoc; adjust weak ack explanations; fix flapping AmqpPublisherActorTest. (details)
  32. Issue #852: review: added missing "." at end of sentence of weak ack payload (details)
  33. Issue #852: added to ConnectionValidator validation for that for all Connection targets the potentially declared "issuedAcknowledgementLabel" may only be issued once (details)
  34. Issue #852: do not publish requests for target-issued acks. (details)
  35. Issue #852: fix javadoc links to scala classes in the same model. (details)
  36. don't use DittoLoggerFactory to get logger in AbstractStreamingActor in order to prevent scala/java/javadoc compile errors due to compile circular dependencies within this module (details)
Commit d9b9142585cfabd2d7715f9ed6af9492b486469e by Yannic Klem
add isWeak flag to acknowledgement

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeaderDefinition.java (diff)
The file was modifiedsignals/acks/base/src/main/java/org/eclipse/ditto/signals/acks/base/ImmutableAcknowledgement.java (diff)
The file was modifiedsignals/acks/base/src/main/java/org/eclipse/ditto/signals/acks/base/Acknowledgement.java (diff)
The file was modifiedsignals/acks/base/src/test/java/org/eclipse/ditto/signals/acks/base/ImmutableAcknowledgementTest.java (diff)
Commit c4670fcdb574455a969f47ccbff777109c61aa65 by Yannic Klem
Let WebSocketRoute issue a weak acknowledgement for all labels of a
signal that is filtered because of the rql filter

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSession.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebSocketRoute.java (diff)
Commit 209fc997a323d98621fb81e695d620861d9ed93e by Yufei Cai
Issue #852: change key type of declared ack labels DData from ActorRef to Address.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/ClusterMemberRemovedAware.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/PubSupervisor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/literal/LiteralDDataHandler.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/compressed/CompressedDData.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/literal/LiteralDData.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/TestPubSubFactory.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/Publisher.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AcksUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractDDataHandler.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/DData.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/PubUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractPubSubSupervisor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/DDataReader.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/compressed/CompressedDDataHandler.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/DDataWriter.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubSupervisor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSubImpl.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/AbstractPubSubFactory.java (diff)
Commit 143ebe8ccf256b4c85299f4bdd053890ace5e98a by Yufei Cai
Issue #852: Fix ImmutableDittoHeadersTest.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedmodel/base/src/test/java/org/eclipse/ditto/model/base/headers/ImmutableDittoHeadersTest.java (diff)
Commit 8facd90ea07a4475aa8beddd5ead43a93ec552d1 by Yannic Klem
Issue #852: Issue weak acknowledgements for rql filtered signals in connectivity

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/SignalFilter.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/SignalFilterWithFilterTest.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)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/SignalFilterTest.java (diff)
Commit 9a156bd9e285fca5451226091758f25b38f49c65 by Yannic Klem
Issue #852: Document weak acknowledgements

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-acknowledgements.md (diff)
Commit d709494b789c6f487ed410d876c4871f4d3f8195 by Yufei Cai
Issue #852: Extract acks ddata as its own extension.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubSupervisor.java (diff)
The file was modifiedservices/concierge/starter/src/main/resources/concierge.conf (diff)
The file was modifiedservices/models/things/src/main/java/org/eclipse/ditto/services/models/things/ThingEventPubSubFactory.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/DittoProtocolSubImpl.java (diff)
The file was modifiedservices/concierge/starter/src/main/java/org/eclipse/ditto/services/concierge/starter/proxy/DefaultEnforcerActorFactory.java (diff)
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSubImpl.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactoryTest.java (diff)
The file was modifiedservices/gateway/starter/src/main/resources/gateway.conf (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactory.java (diff)
The file was modifiedservices/gateway/starter/src/main/java/org/eclipse/ditto/services/gateway/starter/GatewayRootActor.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedAcksImpl.java
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/TestPubSubFactory.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/LiveSignalPub.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedAcksEmptyImpl.java
The file was modifiedservices/models/concierge/src/main/resources/ditto-protocol-subscriber.conf (diff)
The file was modifiedservices/things/starter/src/main/java/org/eclipse/ditto/services/things/starter/ThingsRootActor.java (diff)
The file was modifiedservices/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/SearchUpdaterRootActor.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/DittoProtocolSub.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedAcks.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSub.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AcksSupervisor.java
The file was modifiedservices/connectivity/starter/src/main/java/org/eclipse/ditto/services/connectivity/actors/ConnectivityRootActor.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/LiveSignalPubSubFactory.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/LiveSignalPubImpl.java (diff)
The file was modifiedservices/things/starter/src/main/resources/things.conf (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/AbstractPubSubFactory.java (diff)
Commit a9637cc7232078a7fed6f8ba587d9ceff0ed6a77 by Yufei Cai
Issue #852: add means for other actors to receive local and remote ack declarations.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AcksSupervisor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactoryTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AcksUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedAcksImpl.java (diff)
Commit e749a41972e1eb0907220c6717fc496cb1be8ca9 by Yufei Cai
Issue #852: Send weak acks from publishers.end weak ACK

In addition, publishers maintains ddata snapshots instead of
requesting a snapshot from the replicator every message.
This should improve throughput at the cost of a slight delay
between ddata replication and new subscriptions becoming effective
for a publisher.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedPub.java (diff)
The file was modifiedservices/things/starter/src/test/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceOperationsActorIT.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/AbstractPubSubFactory.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/Publisher.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/DDataReader.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractDDataHandler.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedPubWithTopicExtractor.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/PersistenceActorTestBase.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebSocketRoute.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedPubImpl.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/PubSupervisor.java (diff)
The file was modifiedservices/concierge/enforcement/src/test/java/org/eclipse/ditto/services/concierge/enforcement/TestSetup.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactoryTest.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/TestPubSubFactory.java (diff)
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/LiveSignalEnforcement.java (diff)
Commit c44d7bfcfc887af8d462c29be2096740ac30255c by Yufei Cai
Issue #852: stabilize PubSubFactoryTest.

It is not possible to know when the publisher gets the topic
or ack declaration data replicated. Simply wait 5 heartbeats
in the test whenever replication is expected.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactoryTest.java (diff)
The file was modifiedservices/utils/pubsub/src/test/resources/pubsub-factory-test.conf (diff)
Commit b5c9f52e76fc84fd62cefdf133842e9b3f8c6c6c by Yufei Cai
Issue #852: Send weak-acks from the subscriber side.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/test/resources/pubsub-factory-test.conf (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedPub.java (diff)
The file was modifiedservices/concierge/enforcement/src/test/java/org/eclipse/ditto/services/concierge/enforcement/TestSetup.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/LiveSignalPubSubFactory.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/extractors/AckExtractor.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/extractors/AckExtractorImpl.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/Publisher.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedPubWithTopicExtractor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/Subscriber.java (diff)
The file was modifiedservices/things/starter/src/test/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceOperationsActorIT.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/AbstractPubSubFactory.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff)
The file was addedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/TestMappingStrategies.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedPubImpl.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubSupervisor.java (diff)
The file was modifiedservices/models/things/src/main/java/org/eclipse/ditto/services/models/things/ThingEventPubSubFactory.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/PersistenceActorTestBase.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactoryTest.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/TestPubSubFactory.java (diff)
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/LiveSignalEnforcement.java (diff)
Commit 5164604b6bf45df61d75b381654717793e4886e3 by Yufei Cai
Issue #852: Review: rename header for weak ack; remove TODO.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedsignals/acks/base/src/test/java/org/eclipse/ditto/signals/acks/base/ImmutableAcknowledgementTest.java (diff)
The file was modifiedmodel/base/src/test/java/org/eclipse/ditto/model/base/headers/ImmutableDittoHeadersTest.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeaderDefinition.java (diff)
The file was modifiedsignals/acks/base/src/main/java/org/eclipse/ditto/signals/acks/base/ImmutableAcknowledgement.java (diff)
The file was modifiedsignals/acks/base/src/main/java/org/eclipse/ditto/signals/acks/base/Acknowledgement.java (diff)
Commit 469d041ba55de2adc3a703ebce3658a584cafbc7 by Yufei Cai
Issue #852: Update header name for documentation of WACKs. Adjust wording.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-acknowledgements.md (diff)
Commit f312b306f791dc6fff34202fc1b57373dcb1eef4 by Thomas Jaeckle
fixed remaining loggers which were not threadsafe
* removed LogUtil obsolete functionality in order to enhance MDC with correlation-id (this is now handled by the DittoLoggers)

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/DeleteThingStrategy.java (diff)
The file was modifiedservices/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/AbstractProxyActor.java (diff)
The file was removedservices/connectivity/util/src/main/java/org/eclipse/ditto/services/connectivity/util/ConnectionLogUtil.java
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/PolicyCommandEnforcement.java (diff)
The file was modifiedservices/utils/cache-loaders/src/main/java/org/eclipse/ditto/services/utils/cacheloaders/ActorAskCacheLoader.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/ConnectionDeletedStrategies.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/util/src/test/resources/test.conf
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/AbstractCommandStrategyTest.java (diff)
The file was modifiedservices/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingsUpdater.java (diff)
The file was modifiedservices/utils/cache-loaders/src/main/java/org/eclipse/ditto/services/utils/cacheloaders/PolicyCommandFactory.java (diff)
The file was modifiedservices/utils/devops/src/main/java/org/eclipse/ditto/services/utils/devops/DevOpsCommandsActor.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/strategies/commands/ModifyThingStrategy.java (diff)
The file was modifiedservices/concierge/enforcement/src/test/java/org/eclipse/ditto/services/concierge/enforcement/PolicyCommandEnforcementTest.java (diff)
The file was modifiedservices/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/NewEventForwarder.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractPersistentActorWithTimersAndCleanup.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/DefaultMuteableConnectionLogger.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/actors/ConciergeForwarderActor.java (diff)
The file was modifiedservices/utils/aggregator/src/main/java/org/eclipse/ditto/services/utils/aggregator/ThingsAggregatorProxyActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/CreateConnectionStrategy.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/ModifyConnectionStrategy.java (diff)
The file was modifiedservices/utils/cache-loaders/src/main/java/org/eclipse/ditto/services/utils/cacheloaders/ThingCommandFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/AbstractConnectivityCommandStrategy.java (diff)
The file was modifiedservices/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/QueryThingsPerRequestActor.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractShardedPersistenceActor.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/AbstractCommandStrategies.java (diff)
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/LiveSignalEnforcement.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/utils/metrics/src/main/java/org/eclipse/ditto/services/utils/metrics/instruments/timer/ExpiringTimerBuilder.java (diff)
The file was removedservices/connectivity/util/src/test/java/org/eclipse/ditto/services/connectivity/util/ConnectionLogUtilTest.java
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/AbstractCommandStrategy.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/AbstractMqttConsumerActor.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/CreatePolicyStrategy.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/LogUtil.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/CommandStrategy.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/etags/AbstractConditionHeaderCheckingCommandStrategy.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/strategies/commands/ConnectionConflictStrategy.java (diff)
The file was modifiedservices/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/AbstractThingProxyActor.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/strategies/commands/DeletePolicyStrategy.java (diff)
The file was removedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/LogUtilTest.java
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/ThingCommandEnforcement.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQConsumerActor.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/commands/DefaultContext.java (diff)
The file was modifiedservices/concierge/starter/src/main/java/org/eclipse/ditto/services/concierge/starter/actors/ThingsAggregatorActor.java (diff)
Commit d02d3231d6a718e0b061b7c3f48d5773542fc1c1 by Thomas Jaeckle
fixed unit test

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/DefaultMuteableConnectionLoggerTest.java (diff)
Commit 1870420f7b25f520daeef2aa4f6c16df6202039e by Thomas Jaeckle
try to stabilize unit test

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
Commit 8ceb7b1fafd5b1906fb8348e1d5943d585991f9b by Thomas Jaeckle
fixed shard statistics namespace grouping (was broken for thing names containing a ":")

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/utils/cluster/src/main/java/org/eclipse/ditto/services/utils/cluster/RetrieveStatisticsDetailsResponseSupplier.java (diff)
Commit 90e682b71c44f90f700503a3d99cf032e86d782c by Yannic Klem
Delay publishing of subscribe ack in order to ensure that subscribe is
published within the cluster

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/utils/ddata/src/test/resources/akka-replicator-ddata-test.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java (diff)
The file was modifiedservices/utils/ddata/src/test/resources/ditto-ddata-test.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/utils/ddata/src/main/java/org/eclipse/ditto/services/utils/ddata/DefaultAkkaReplicatorConfig.java (diff)
The file was modifiedservices/utils/ddata/src/test/java/org/eclipse/ditto/services/utils/ddata/DefaultAkkaReplicatorConfigTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSubImpl.java (diff)
The file was modifiedservices/utils/ddata/src/main/java/org/eclipse/ditto/services/utils/ddata/AkkaReplicatorConfig.java (diff)
Commit 2aa45e640883abdc29e4bc15df6bd056aebe9f61 by Yufei Cai
Issue #852: change how connectivity issues weak acks.

- ConnectionPersistenceActor: issue weak acks for all requested
  source-declared or target-issued custom acks if signal is dropped
  due to authorization or RQL filter before enrichment.

- OutboundMappingProcessorActor: issue weak acks for all requested
  source-declared or target-issued custom acks if signal is dropped
  at all targets due to payload mapping or RQL filter after
  enrichment.

- OutboundMappingProcessorActor: issue weak acks for requested
  target-issued acknowledgements if some but not all targets
  dropped the signal due to payload mapping or RQL filter after
  enrichment.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActorTest.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MockProxyActor.java (diff)
Commit 9581d00fc4289430b444fac99595a23dbc3ac0a4 by Yannic Klem
Increase flapdoodle version to 3.0.0

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedbom/pom.xml (diff)
The file was modifiedservices/utils/test/src/test/java/org/eclipse/ditto/services/utils/test/mongo/MongoDbResource.java (diff)
Commit 3205bad79f1b4f663323086f05d2c1cfcb82ec20 by Yufei Cai
Issue #852: Fix 2 TODOs.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/SignalFilter.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/SignalFilterTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/SignalFilterWithFilterTest.java (diff)
Commit 7f97897bd25c22b595f2293373d297df680d89a6 by Yufei Cai
Issue #852: Remove waiting for heartbeats after subscription in PubSubFactoryTest.

The notify-subscribers-delay is now baked into subscription.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactoryTest.java (diff)
Commit 2bccfdb68fff578ffa3fe82e2bf65a9423d95e14 by Yufei Cai
Issue #852: Remove LogUtil.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MockClientActor.java (diff)
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/AbstractHealthCheckingActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/RetrieveConnectionLogsAggregatorActor.java (diff)
The file was modifiedservices/utils/cluster/src/main/java/org/eclipse/ditto/services/utils/cluster/AbstractPubSubListenerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/metrics/RetrieveConnectionMetricsAggregatorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ReconnectActor.java (diff)
The file was removedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/LogUtil.java
The file was modifiedservices/concierge/enforcement/src/test/java/org/eclipse/ditto/services/concierge/enforcement/MockEntitiesActor.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/policies/starter/src/main/java/org/eclipse/ditto/services/policies/starter/PoliciesRootActor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/PubSupervisor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/FaultyClientActor.java (diff)
The file was modifiedservices/things/starter/src/main/java/org/eclipse/ditto/services/things/starter/ThingsRootActor.java (diff)
The file was modifiedservices/utils/namespaces/src/main/java/org/eclipse/ditto/services/utils/namespaces/BlockedNamespacesUpdater.java (diff)
The file was modifiedservices/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/StatisticsActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/TestConstants.java (diff)
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/status/StatusSupplierActor.java (diff)
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/streaming/AbstractStreamingActor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractPubSubSupervisor.java (diff)
The file was modifiedservices/connectivity/starter/src/main/java/org/eclipse/ditto/services/connectivity/actors/ConnectivityRootActor.java (diff)
The file was modifiedservices/concierge/actors/src/main/java/org/eclipse/ditto/services/concierge/actors/cleanup/credits/MessageAggregator.java (diff)
The file was modifiedservices/utils/devops/src/main/java/org/eclipse/ditto/services/utils/devops/DevOpsCommandsActor.java (diff)
The file was modifiedservices/concierge/starter/src/main/java/org/eclipse/ditto/services/concierge/starter/actors/CachedNamespaceInvalidator.java (diff)
The file was modifiedservices/concierge/starter/src/main/java/org/eclipse/ditto/services/concierge/starter/actors/ConciergeRootActor.java (diff)
The file was modifiedservices/utils/cache-loaders/src/main/java/org/eclipse/ditto/services/utils/cacheloaders/ActorAskCacheLoader.java (diff)
The file was modifiedservices/utils/cluster/src/main/java/org/eclipse/ditto/services/utils/cluster/ClusterSingletonSupervisorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/metrics/RetrieveConnectionStatusAggregatorActor.java (diff)
The file was modifiedservices/gateway/starter/src/main/java/org/eclipse/ditto/services/gateway/starter/GatewayRootActor.java (diff)
The file was modifiedservices/utils/persistent-actors/src/main/java/org/eclipse/ditto/services/utils/persistentactors/AbstractPersistenceSupervisor.java (diff)
The file was modifiedservices/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/PolicyEventForwarder.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/JMSConnectionHandlingActor.java (diff)
Commit 002e3e513a9d92446ec211319da17a9e91a0b78e by Yufei Cai
Fix 1 TODO in OutboundMappingProcessorActor.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java (diff)
Commit dc76ba8595c5f5d1a96519d45fca0efec1958671 by Yufei Cai
Issue #852: Explain in WACK that it can be issued for a variety of reasons.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebSocketRoute.java (diff)
Commit 5f654d4d462fbfd4dfe564fce0ac3c8ad8f8bf0f by Yufei Cai
Issue #852: add blog post about weak acks.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was addeddocumentation/src/main/resources/_posts/2020-11-05-weak-acknowledgements.md
Commit 00992c483c7bdf9023d36bf86ceb6ae08893a906 by Yufei Cai
Issue #852: edit weak ack blogpost.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifieddocumentation/src/main/resources/_posts/2020-11-05-weak-acknowledgements.md (diff)
Commit 1d8b07ade79f226a838dfec0a5aab24cf98f0919 by Thomas Jaeckle
Issue #852: review of blogpost:
* moved publish date to 16.11.2020
* fixed that ".html" was missing from links
* did some formatting (line breaks)
* fixed some findings in "desired properties" blogpost as well

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifieddocumentation/src/main/resources/_data/authors.yml (diff)
The file was addeddocumentation/src/main/resources/_posts/2020-11-16-weak-acknowledgements.md
The file was modifieddocumentation/src/main/resources/_posts/2020-10-23-end-2-end-acknowledgement.md (diff)
The file was modifieddocumentation/src/main/resources/_posts/2020-11-11-desired-properties.md (diff)
The file was removeddocumentation/src/main/resources/_posts/2020-11-05-weak-acknowledgements.md
Commit bc28e9aaca961dd1017634e8960d17594078a342 by marianne.klein
CR-8422 - add ditto-weak-ack header in table

Signed-off-by: Marianne Klein <marianne.klein@bosch.io>
The file was modifieddocumentation/src/main/resources/pages/ditto/protocol-specification.md (diff)
Commit 0a34f12664449d83c785277f24690459fd2da5ac by Thomas Jaeckle
Issue #852: remove existing "requested-acks" DittoHeader when creating an ImmutableAcknowledgement and an ImmutableAcknowledgements
* the header does not make sense for Acks themselves but only for the Singals which caused an Ack to be created

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/models/acks/src/test/java/org/eclipse/ditto/services/models/acks/AcknowledgementAggregatorActorTest.java (diff)
The file was modifiedsignals/acks/base/src/main/java/org/eclipse/ditto/signals/acks/base/ImmutableAcknowledgement.java (diff)
The file was modifiedsignals/acks/base/src/main/java/org/eclipse/ditto/signals/acks/base/ImmutableAcknowledgements.java (diff)
The file was modifiedsignals/acks/base/src/test/java/org/eclipse/ditto/signals/acks/base/ImmutableAcknowledgementTest.java (diff)
Commit ea5f7f2a3fcf8d4588d509750a0b5feb6d837f59 by Yufei Cai
Issue #852: fix javadoc; adjust weak ack explanations; fix flapping AmqpPublisherActorTest.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedsignals/acks/base/src/main/java/org/eclipse/ditto/signals/acks/base/Acknowledgement.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/extractors/AckExtractor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActorTest.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebSocketRoute.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java (diff)
Commit 116b2ca1aeb941caa10ae8663971a18135a9bec2 by Thomas Jaeckle
Issue #852: review: added missing "." at end of sentence of weak ack payload
* added missing "@since" javadoc annotations to new public methods in Acknowledgement

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/extractors/AckExtractor.java (diff)
The file was modifiedsignals/acks/base/src/main/java/org/eclipse/ditto/signals/acks/base/Acknowledgement.java (diff)
Commit b398dfac2a02026f759eaa56c028db35c61c4c77 by Thomas Jaeckle
Issue #852: added to ConnectionValidator validation for that for all Connection targets the potentially declared "issuedAcknowledgementLabel" may only be issued once

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidator.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java (diff)
Commit 612781fae49e3a9919544be5ad32fd6872b854e6 by Thomas Jaeckle
Issue #852: do not publish requests for target-issued acks.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActorTest.java (diff)
Commit aae72c6e15261bc07c3ea38af338ede27a7348d2 by Yufei Cai
Issue #852: fix javadoc links to scala classes in the same model.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/logging/DittoLoggerFactory.java (diff)
Commit 093c82cdb901b773dffa82364538d60d27229bd4 by Thomas Jaeckle
don't use DittoLoggerFactory to get logger in AbstractStreamingActor in order to prevent scala/java/javadoc compile errors due to compile circular dependencies within this module

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/streaming/AbstractStreamingActor.java (diff)