SuccessChanges

Summary

  1. Issue #878: [WIP] add local and remote data structures for declared ack labels with group. (details)
  2. Issue #878: [WIP] add AckSupervisor; test AckUpdater (failing) (details)
  3. 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)
  4. Issue #878: switch AckUpdater to LiteralDData for ease of serialization; test remote conflict. (details)
  5. Issue #878: test & fix a local conflict case for AckUpdater; add javadoc. (details)
  6. Issue #878: review: moved inner classes of AbstractUpdater into own "API" package (details)
  7. Issue #878: Replace AcksUpdater by AckUpdater. (details)
  8. Issue #878: move AckUpdater messages to package /api. (details)
  9. Issue #878: replace GroupedAckLabels by Grouped for use in topics ddata. (details)
  10. Issue #878: hardcode hash family size to 2; switch compressed topic type from ByteString to Long to prepare for JSON serialization. (details)
  11. Issue #878: add group to topics ddata; remove incrememental update. (details)
  12. Issue #878: add command to publish signals with groups. (details)
  13. Issue #878: Restrict published messages to signals. (details)
  14. Issue #878: Fix serialization of PublishCommand. (details)
  15. Issue #878: Fix parsing of non-recursive jsonifiable.. (details)
  16. Issue #878: distribute signals according to groups on the publisher side. (details)
  17. Issue #878: distribute published messages according to groups at the subscriber. (details)
  18. Issue #878: add methods to declare ack labels and subscribe in a group. (details)
  19. Issue #878: restrict weak acks to chosen groups; fix ConnectionPersistenceActorTest; fix that grouped ack label declarations conflict with themselves. (details)
  20. Issue #878: make client actors aware of each other; fix StreamingSessionActorHeaderInteractionTest. (details)
  21. Issue #878: move auth and acknowledgement forwarding from ConnectionPersistenceActor to OutboundDispatchingActor; add InboundSignal; fix deserialization of null event metadata. (details)
  22. Issue #878: turn DittoProtocolSub into an actor system extension. (details)
  23. Issue #878: fix dropping of search events due to same origin. (details)
  24. Issue #878: review: fixed just some minor cosmetic final/import stuff (details)
  25. Issue #878: add random gossip between client actors to recover from message loss; make client actors watch each other to remove zombies from cache. (details)
  26. Issue #878: review: renamed methid PublisherIndex.allot... to assign... (details)
  27. Issue #878: move event subscription from connection persistence actor to client actors. (details)
  28. Issue #878: add javadoc for the group-size relation of PublishSignal. (details)
  29. Issue #878: Remove the detour of ThingSearchCommand via connection persistence actor where possible. (details)
  30. Issue #878: Make client actors talk to the local proxy actor only. (details)
  31. Issue #878: review: removed no longer used method DistributedSub#subscribeWithAck (details)
  32. Issue #878: add and test pubsub recovery behavior. (details)
  33. Issue #878: fix javadoc errors. (details)
  34. Issue #878: migrate connection persistence actor tests & fix them. (details)
  35. Issue #878: review: minor naming stuff; Sonar fix (details)
  36. Issue #878: review: not issue-related cleanup stuff (details)
  37. Issue #878: add config option to start all client actors on the same node. (details)
  38. Issue #878: Fix various TODOs; add test for invalid subscription ID. (details)
  39. Issue #878: Use connection ID as client ID if the connection has 1 client. (details)
  40. Issue #878: fix "refreshAfterWrite" exception with loader. (details)
  41. Issue #878: Replace WRITE_ALL consistency of topics ddata by optimistic waiting. (details)
  42. Issue #878: update ddata metrics; remove useless params and mocks. (details)
  43. Issue #878: remove unused class LiteralSubscriptions. (details)
  44. Issue #878: re-introduce diff-based ddata updates. (details)
  45. Issue #878: Make replication delay estimation less pessimistic. (details)
  46. Issue #878: Make replication delay estimation more pessimistic; fix a double assignment in AckSupervisor. (details)
  47. Issue #878: [wip] try reverting to write-consistency-based SubAck for topic subscriptions (details)
  48. Issue #878: Move all pubsub-related classes to the same module. (details)
  49. Issue #878: Revert 20c64713; make ddata replication delay more pessimistic. (details)
  50. Issue #878: Fix handling of Terminated messages by Pub- and AckSupervisor. (details)
  51. Issue #878: review: adjusted javadoc in Subscriptions (details)
  52. Issue #878: review: renamed LiteralUpdate.replaceAll method to withInserts; fixed toString() (details)
  53. Issue #878: review: fixed calculation of "change" in AbstractSubscriptions (details)
  54. fixed logging of exception in AmqpPublisherActor (details)
  55. Issue #878: replace instance ID by default client ID in BasePublisherActor. (details)
  56. Issue #878: stabilize MQTT client actor tests; remove unused metric. (details)
  57. Issue #878: configure pubsub with a small ddata notify-subscribers-interval for responsiveness. (details)
  58. Issue #878: review: removed "final" from interface method (details)
  59. Issue #878: review: replaced "-" separator of connectionId and random UUID for "clientId" with "_" in order to be able to easily split 2 UUIDs (details)
  60. Issue #878: Reorder CreateConnection stages to stabilize ConnectionPersistenceActorTest.enabledConnectionLogsAreEnabledAgainAfterModify. (details)
Commit bcdeac5cfee779fc6eeea6035be05196427035c1 by Yufei Cai
Issue #878: [WIP] add local and remote data structures for declared ack labels with group.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/GroupedSnapshot.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/Grouped.java
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/AbstractSubscriptions.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/DDataUpdate.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/AckDDataUpdate.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractSubscriptionsUpdate.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/AckDData.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/compressed/CompressedUpdate.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/package-info.java
The file was removedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/IndelUpdate.java
The file was removedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractIndelUpdate.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/GroupedRelation.java
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractSubscriptionsTest.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdater.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/literal/LiteralUpdate.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/AckDDataHandler.java
Commit 7ed38bb746c933c9adfb2499035ebe38bf6ed3cb by Yufei Cai
Issue #878: [WIP] add AckSupervisor; test AckUpdater (failing)

- akka.japi.Pair is not serializable. Use a different data structure.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was addedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdaterTest.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdater.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckSupervisor.java
Commit 40f26ec6a3416b65ada7515b3654a128cc858f49 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)
Commit aec7e5aab5f743a512f31629d3d3ab340c8afcda by Yufei Cai
Issue #878: switch AckUpdater to LiteralDData for ease of serialization; test remote conflict.

- Delete AckDData, which uses a non-serializable type akka.japi.Pair
  as value of ORMultiMap.

- Opted to use String as value type of ORMultiMap and deserialize
  on each ddata change notification. This way, sweeping changes to
  serialization configuration in all dependent services are avoided.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was removedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/AckDDataHandler.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckSupervisor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdater.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/GroupedAckLabels.java
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdaterTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/AbstractPubSubFactory.java (diff)
The file was removedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/AckDData.java
The file was removedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/AckDDataUpdate.java
Commit e866d6e74cd54b9eb1b4404791af18101b924fe2 by Yufei Cai
Issue #878: test & fix a local conflict case for AckUpdater; add javadoc.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/GroupedSnapshot.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/package-info.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/GroupedRelation.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/Grouped.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/GroupedAckLabels.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdaterTest.java (diff)
Commit 8e683aa8ff0493c4daed93b3587a05e048f77fb5 by Thomas Jaeckle
Issue #878: review: moved inner classes of AbstractUpdater into own "API" package
* made abstract classes package private where now feasible
* small javadoc adjustments

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AcksSupervisor.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/literal/AbstractConfigAwareDDataProvider.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/SubAck.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/Unsubscribe.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractUpdater.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubscriptionsChanged.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/LiteralDDataProvider.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/Request.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/AbstractRequest.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/RemoveSubscriber.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/DDataChanged.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/Subscribe.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedAcksImpl.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/DistributedAcks.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckSupervisor.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/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/AbstractPubSubSupervisor.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/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdaterTest.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/actors/AcksUpdater.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/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/DistributedAcksEmptyImpl.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/ddata/TopicData.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSub.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/Grouped.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/Publisher.java (diff)
Commit bfff23a40c3c9fa87057c8ccb24d9f7c9bb1b960 by Yufei Cai
Issue #878: Replace AcksUpdater by AckUpdater.

- Add serialization and deserialization of grouped acknowledgement
  label declarations.

- Add typed change notifications from AckUpdater.

- Handle remote racing.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/RemoteAcksChanged.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/package-info.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/GroupedRelation.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedAcks.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedAcksEmptyImpl.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/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedAcksImpl.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/GroupedSnapshot.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/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/AckSupervisor.java (diff)
The file was removedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AcksSupervisor.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/GroupedAckLabels.java (diff)
The file was removedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AcksUpdater.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/LocalAcksChanged.java
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdaterTest.java (diff)
Commit 43e620360697c7ee08ee4626d2a7d189507eaf12 by Yufei Cai
Issue #878: move AckUpdater messages to package /api.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdaterTest.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/DeclareAcks.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdater.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/ReceiveRemoteAcks.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/RemoveSubscriberAcks.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedAcksEmptyImpl.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedAcks.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/AcksDeclared.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/ReceiveAckChanges.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedAcksImpl.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/AckRequest.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckSupervisor.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/ReceiveLocalAcks.java
Commit 928792b2e5d8cf4208074470231f18f9f0988955 by Yufei Cai
Issue #878: replace GroupedAckLabels by Grouped for use in topics ddata.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdaterTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/Grouped.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/RemoteAcksChanged.java (diff)
The file was removedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/GroupedAckLabels.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdater.java (diff)
Commit 79e6eb1d4bfcb3e3f636795240191cdc87adac07 by Yufei Cai
Issue #878: hardcode hash family size to 2; switch compressed topic type from ByteString to Long to prepare for JSON serialization.
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/config/PubSubConfig.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/Hashes.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/config/DefaultPubSubConfigTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/resources/reference.conf (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/compressed/CompressedSubscriptions.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/compressed/CompressedUpdate.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/test/java/org/eclipse/ditto/services/utils/pubsub/ddata/compressed/CompressedSubscriptionsTest.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/actors/AbstractPubSubSupervisor.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/config/DefaultPubSubConfig.java (diff)
Commit 12800d66d5f8b9cf4c6000a934a98261d7024038 by Yufei Cai
Issue #878: add group to topics ddata; remove incrememental update.

Incremental update removed due to losing granuality of topics
in the distributed data.

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/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/Subscriptions.java (diff)
The file was removedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/compressed/CompressedUpdate.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/config/DefaultPubSubConfig.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/literal/LiteralUpdate.java (diff)
The file was removedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubscriptionsChanged.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractUpdater.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/SubscriberData.java
The file was removedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/DDataChanged.java
The file was modifiedservices/utils/pubsub/src/main/resources/reference.conf (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractSubscriptionsTest.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/compressed/CompressedDDataHandler.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/config/PubSubConfig.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractSubscriptions.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/compressed/CompressedSubscriptions.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/Subscribe.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/DDataUpdate.java (diff)
The file was removedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/ddata/compressed/CompressedSubscriptionsTest.java
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/test/java/org/eclipse/ditto/services/utils/pubsub/config/DefaultPubSubConfigTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/Hashes.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/SubUpdater.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/ddata/literal/LiteralSubscriptions.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/actors/AckUpdater.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/ddata/AbstractSubscriptionsUpdate.java (diff)
Commit 18a2f751cf940293eafe4a8ae6277dab25d3ee12 by Yufei Cai
Issue #878: add command to publish signals with groups.

Command deserialization is extended to give recursive access
to the registry in order to deserialize inner signals.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/PublishSignal.java
The file was modifiedsignals/base/src/main/java/org/eclipse/ditto/signals/base/AbstractJsonParsableRegistry.java (diff)
The file was modifiedsignals/base/src/main/java/org/eclipse/ditto/signals/base/AnnotationBasedJsonParsable.java (diff)
The file was modifiedservices/concierge/starter/src/test/java/org/eclipse/ditto/services/concierge/starter/ConciergeServiceGlobalCommandRegistryTest.java (diff)
The file was modifiedservices/things/starter/src/test/java/org/eclipse/ditto/services/things/starter/ThingsServiceGlobalCommandRegistryTest.java (diff)
The file was modifiedservices/gateway/starter/src/test/java/org/eclipse/ditto/services/gateway/starter/GatewayServiceGlobalCommandRegistryTest.java (diff)
The file was modifiedservices/thingsearch/starter/src/test/java/org/eclipse/ditto/services/thingsearch/starter/ThingsSearchServiceGlobalCommandRegistryTest.java (diff)
The file was modifiedservices/utils/test/src/test/java/org/eclipse/ditto/services/utils/test/GlobalCommandRegistryTestCases.java (diff)
The file was modifiedsignals/base/src/test/java/org/eclipse/ditto/signals/base/GlobalErrorRegistryTest.java (diff)
The file was modifiedsignals/base/src/main/java/org/eclipse/ditto/signals/base/JsonParsable.java (diff)
The file was modifiedservices/connectivity/starter/src/test/java/org/eclipse/ditto/services/connectivity/ConnectivityServiceGlobalCommandRegistryTest.java (diff)
Commit ec4fd693bdf8e7be0f7bfec4f65d033023a91528 by Yufei Cai
Issue #878: Restrict published messages to signals.

Reason: Serialization of PublishSignal command.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
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/PubSubFactory.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedPub.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/DistributedPubImpl.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/test/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactoryTest.java (diff)
Commit 0dff3981d5d66287adf8ceef3414de7297af633c by Yufei Cai
Issue #878: Fix serialization of PublishCommand.

Inner signal may not be a command. Should recurse onto mapping
strategies level instead of the same (command) registry.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/cluster/src/main/java/org/eclipse/ditto/services/utils/cluster/AbstractJsonifiableWithDittoHeadersSerializer.java (diff)
The file was modifiedsignals/base/src/main/java/org/eclipse/ditto/signals/base/AnnotationBasedJsonParsable.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/PublishSignal.java (diff)
The file was modifiedsignals/base/src/main/java/org/eclipse/ditto/signals/base/AbstractJsonParsableRegistry.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/Subscriber.java (diff)
The file was modifiedsignals/base/src/main/java/org/eclipse/ditto/signals/base/JsonParsable.java (diff)
The file was modifiedservices/utils/cluster/src/main/java/org/eclipse/ditto/services/utils/cluster/GlobalMappingStrategies.java (diff)
The file was modifiedservices/utils/cluster/src/main/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilder.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/Publisher.java (diff)
Commit 187a8cbfa2133dc53fe5c49dbf770e7d66bd4bcb by Yufei Cai
Issue #878: Fix parsing of non-recursive jsonifiable..

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/test/src/test/java/org/eclipse/ditto/services/utils/test/GlobalCommandRegistryTestCases.java (diff)
The file was modifiedsignals/base/src/main/java/org/eclipse/ditto/signals/base/AnnotationBasedJsonParsable.java (diff)
Commit e269d5531e84145b1396f081ac6f963e98b6fd19 by Yufei Cai
Issue #878: distribute signals according to groups on the publisher side.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSub.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSubImpl.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/PublisherIndex.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/api/PublishSignal.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/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/SubUpdater.java (diff)
Commit 87f46cf68c7bcfd778f2e9f332974d5e488415e0 by Yufei Cai
Issue #878: distribute published messages according to groups at the subscriber.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractSubscriptions.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/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/PublishSignal.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/TopicData.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/SubscriberData.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/PublisherIndex.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/Subscriptions.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSub.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/compressed/CompressedSubscriptions.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/Subscribe.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/ddata/SubscriptionsReader.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/ddata/literal/LiteralSubscriptions.java (diff)
Commit 9651a830758c7152d31d586c37c4e809a1403593 by Yufei Cai
Issue #878: add methods to declare ack labels and subscribe in a group.

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/AckUpdater.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/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/TestConstants.java (diff)
The file was modifiedservices/gateway/streaming/src/test/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActorHeaderInteractionTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/literal/LiteralUpdate.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/DittoProtocolSubImpl.java (diff)
The file was modifiedservices/gateway/streaming/src/test/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActorTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedAcksImpl.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/DittoProtocolSub.java (diff)
The file was removedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractSubscriptionsUpdate.java
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdaterTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedAcksEmptyImpl.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/RemoteAcksChanged.java (diff)
The file was modifiedservices/connectivity/starter/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceOperationsActorIT.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedAcks.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
Commit 48420eadc62099d906c3f64a985c1220e475e332 by Yufei Cai
Issue #878: restrict weak acks to chosen groups; fix ConnectionPersistenceActorTest; fix that grouped ack label declarations conflict with themselves.

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/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/GroupedSnapshot.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/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/ack/GroupedRelation.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdater.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/RemoteAcksChanged.java (diff)
The file was modifiedservices/gateway/streaming/src/test/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActorTest.java (diff)
Commit 6da2cccb8929312cc50496090506491a7215649e by Yufei Cai
Issue #878: make client actors aware of each other; fix StreamingSessionActorHeaderInteractionTest.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/PublisherIndex.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ClientActorRefs.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/gateway/streaming/src/test/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActorHeaderInteractionTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActorTest.java (diff)
Commit 542384f16302bfe37f0091014372b5a2609c146b by Yufei Cai
Issue #878: move auth and acknowledgement forwarding from ConnectionPersistenceActor to OutboundDispatchingActor; add InboundSignal; fix deserialization of null event metadata.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
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/httppush/HttpPushClientActorTest.java (diff)
The file was addedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/InboundSignal.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQClientActorTest.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingSettings.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
The file was addedservices/models/connectivity/src/test/resources/test.conf
The file was modifiedservices/models/connectivity/src/main/java/org/eclipse/ditto/services/models/connectivity/ConnectivityMappingStrategies.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/InboundDispatchingActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/SignalFilter.java (diff)
The file was modifiedsignals/events/base/src/main/java/org/eclipse/ditto/signals/events/base/EventJsonDeserializer.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ClientActorRefs.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundDispatchingActor.java
The file was addedservices/models/connectivity/src/test/java/org/eclipse/ditto/services/models/connectivity/InboundSignalTest.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/AbstractMqttClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessor.java (diff)
Commit 6bf7e9666244a39ab84d0f0fd5a3f3939c31ef82 by Yufei Cai
Issue #878: turn DittoProtocolSub into an actor system extension.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/models/things/src/main/java/org/eclipse/ditto/services/models/things/ThingEventPubSubFactory.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedAcksImpl.java (diff)
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/DittoProtocolSubImpl.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/gateway/starter/src/main/java/org/eclipse/ditto/services/gateway/starter/GatewayRootActor.java (diff)
The file was modifiedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/DittoProtocolSub.java (diff)
The file was modifiedservices/connectivity/starter/src/main/java/org/eclipse/ditto/services/connectivity/actors/ConnectivityRootActor.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/DistributedAcks.java (diff)
Commit be3a5f2ad043c3966ce73a59e993a375490c1812 by Yufei Cai
Issue #878: fix dropping of search events due to same origin.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundDispatchingActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundDispatchingActor.java (diff)
Commit a93ad27621b5d3fc7e1e85078e878d8df91b5fe4 by Thomas Jaeckle
Issue #878: review: fixed just some minor cosmetic final/import stuff

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
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/DistributedSub.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/Subscriptions.java (diff)
Commit 05d35912573b9a9d9a713e6b344a4e701f3aad06 by Yufei Cai
Issue #878: add random gossip between client actors to recover from message loss; make client actors watch each other to remove zombies from cache.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultClientConfig.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/config/ClientConfig.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/resources/client-test.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ClientActorRefs.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultClientConfigTest.java (diff)
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
Commit 0792e184ab1dc597b40ef3ff73418454226a5d14 by Thomas Jaeckle
Issue #878: review: renamed methid PublisherIndex.allot... to assign...

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
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/PublisherIndex.java (diff)
The file was modifiedsignals/base/src/main/java/org/eclipse/ditto/signals/base/AbstractJsonParsableRegistry.java (diff)
The file was modifiedsignals/base/src/main/java/org/eclipse/ditto/signals/base/JsonParsable.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/Subscriber.java (diff)
Commit 7c147b3730e71c6cd398072d8fad7728102b8b05 by Yufei Cai
Issue #878: move event subscription from connection persistence actor to client actors.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/TestConstants.java (diff)
The file was modifiedservices/utils/pubsub/src/test/resources/pubsub-factory-test.conf (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/persistence/ConnectionPersistenceActorTest.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/connectivity/starter/src/main/java/org/eclipse/ditto/services/connectivity/actors/ConnectivityRootActor.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/starter/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceOperationsActorIT.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/connectivity/messaging/src/test/resources/test.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundDispatchingActor.java (diff)
The file was modifiedservices/utils/pubsub/src/test/resources/pubsub-test.conf (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionSupervisorActor.java (diff)
Commit d5ababa2bf3860f716822993b0aab0142eb978c7 by Yufei Cai
Issue #878: add javadoc for the group-size relation of PublishSignal.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/PublishSignal.java (diff)
Commit e9fb992ab775a282d0418a85f9244de87fe956f9 by Yufei Cai
Issue #878: Remove the detour of ThingSearchCommand via connection persistence actor where possible.

Client actors now dispatch search commands to each other whenever
they contain a subscription ID to identify the intended recipient.
Only CreateSubscription is routed through the connection persistence
for round-robin subscription ID assignment.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundDispatchingActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ClientActorRefs.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was addedsignals/commands/thingsearch/src/main/java/org/eclipse/ditto/signals/commands/thingsearch/WithSubscriptionId.java
The file was modifiedsignals/commands/thingsearch/src/main/java/org/eclipse/ditto/signals/commands/thingsearch/subscription/RequestFromSubscription.java (diff)
The file was modifiedsignals/commands/thingsearch/src/main/java/org/eclipse/ditto/signals/commands/thingsearch/subscription/CancelSubscription.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MockClientActor.java (diff)
Commit 9572514a2a67d29908899683747be2b6b06e5875 by Yufei Cai
Issue #878: Make client actors talk to the local proxy actor only.

This removes an unnecessary remoting from client actor node to
the connection persistence actor node.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/utils/search/src/test/java/org/eclipse/ditto/services/utils/search/SubscriptionManagerTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundDispatchingActor.java (diff)
The file was modifiedservices/utils/search/src/main/java/org/eclipse/ditto/services/utils/search/SubscriptionManager.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractMessageMappingProcessorActorTest.java (diff)
The file was modifiedservices/utils/search/src/main/java/org/eclipse/ditto/services/utils/search/SearchSource.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/AbstractConsumerActorTest.java (diff)
The file was modifiedservices/utils/search/src/test/java/org/eclipse/ditto/services/utils/search/SearchSourceBuilderTest.java (diff)
The file was modifiedservices/utils/search/src/main/java/org/eclipse/ditto/services/utils/search/SearchSourceBuilder.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingActor.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/sse/ThingsSseRouteBuilder.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActorTest.java (diff)
The file was modifiedservices/utils/search/src/test/java/org/eclipse/ditto/services/utils/search/SearchSourceTest.java (diff)
Commit 4be0f4ef96045de7016de53a24047cd2bd7c6c59 by Thomas Jaeckle
Issue #878: review: removed no longer used method DistributedSub#subscribeWithAck

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSub.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/DistributedSubImpl.java (diff)
Commit 510eaf95e759e109e785b9595d1bc19ef6146fe2 by Yufei Cai
Issue #878: add and test pubsub recovery behavior.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelNotUniqueException.java (diff)
The file was addedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/PubSubTerminatedException.java
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/actors/Subscriber.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedAcksImpl.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/Subscriptions.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/ack/GroupedRelation.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckSupervisor.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/ddata/AbstractSubscriptions.java (diff)
The file was addedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/FatalPubSubException.java
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/PubSubFactoryTest.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/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedAcks.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/AbstractPubSubFactory.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/ActorEvent.java
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/ddata/literal/LiteralSubscriptions.java (diff)
The file was removedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AbstractUpdater.java
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/AckUpdater.java (diff)
Commit 6aa5deaf41bbf704a88874ec6635f356457ffde8 by Yufei Cai
Issue #878: fix javadoc errors.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/PubSubTerminatedException.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/acks/AcknowledgementLabelNotUniqueException.java (diff)
Commit 7125a45ff09fd947ea6cd82333efc2651add2da7 by Yufei Cai
Issue #878: migrate connection persistence actor tests & fix them.

- Tests related to event publishing moved to OutboundDispatchingActorTest.

- Test about search command dispatching moved to BaseClientActorTest.
  Fixed an issue where a portion of the client actors are not getting
  any search command forwarded due to hashing.

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/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/test/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActorTest.java (diff)
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/OutboundDispatchingActorTest.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ClientActorRefs.java (diff)
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MockActor.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckSupervisor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
Commit 1153c428396b63558291ad7d249d93f8d8a5f4da by Thomas Jaeckle
Issue #878: review: minor naming stuff; Sonar fix

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedsignals/commands/thingsearch/src/main/java/org/eclipse/ditto/signals/commands/thingsearch/subscription/CreateSubscription.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java (diff)
Commit 1d8591352b1ee5613385fe4bfc29698a59770be6 by Thomas Jaeckle
Issue #878: review: not issue-related cleanup stuff

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingActor.java (diff)
The file was modifiedservices/utils/search/src/main/java/org/eclipse/ditto/services/utils/search/SearchSource.java (diff)
The file was modifiedservices/base/src/main/java/org/eclipse/ditto/services/base/actors/DittoRootActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ConnectivityProxyActor.java (diff)
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/status/StatusSupplierActor.java (diff)
The file was modifiedsignals/commands/thingsearch/src/main/java/org/eclipse/ditto/signals/commands/thingsearch/subscription/CreateSubscription.java (diff)
Commit 5482022406e2fa39f86abcb726b886aa6cd60e1b by Yufei Cai
Issue #878: add config option to start all client actors on the same node.

For single-connectivity instance deployments, starting multiple client
actors on the same node increases concurrency and reduces the impact
of latency on connection throughput.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActor.java (diff)
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/ConnectionConfig.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActorTest.java (diff)
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/JMSConnectionHandlingActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/JmsConnectionHandlingActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/DefaultKafkaConnectionFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/Thing3ValuePredicateVisitor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/ConnectionBasedJmsConnectionFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/AbstractMqttClientActor.java (diff)
The file was modifiedservices/connectivity/common/src/test/resources/connection-test.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdater.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/amqp/JmsConnectionFactory.java (diff)
The file was modifiedservices/connectivity/common/src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultConnectionConfig.java (diff)
The file was modifiedservices/connectivity/common/src/test/java/org/eclipse/ditto/services/connectivity/config/DefaultConnectionConfigTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/internal/ConnectClient.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/ProducerPropertiesFactory.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/Trilean.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/kafka/ProducerPropertiesFactoryTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaClientActor.java (diff)
Commit e7d5e2c3dc0986d40d4fe0509f3d45b58a65f8a7 by Yufei Cai
Issue #878: Fix various TODOs; add test for invalid subscription ID.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
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/BasePublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActorTest.java (diff)
The file was removedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/AuthenticationResultWaiter.java
The file was modifiedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/TimeMeasuringAuthenticationProvider.java (diff)
The file was modifiedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/controlflow/ResumeSourceTest.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/entity/id/NamespacedEntityIdInvalidException.java (diff)
The file was addedservices/gateway/security/src/main/java/org/eclipse/ditto/services/gateway/security/authentication/AuthenticationResultOrTimeout.java
The file was modifiedservices/utils/cache/src/main/java/org/eclipse/ditto/services/utils/cache/CaffeineCache.java (diff)
Commit a3cfd91780f523fc0e00fbd98a38c49275ee810f by Yufei Cai
Issue #878: Use connection ID as client ID if the connection has 1 client.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/AbstractMqttClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
Commit 993ff3367437f1b050bc059e67532f91bd960686 by Yufei Cai
Issue #878: fix "refreshAfterWrite" exception with loader.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/cache/src/main/java/org/eclipse/ditto/services/utils/cache/CaffeineCache.java (diff)
Commit 6a18da1ebaa3567af3f9aabee21a6cd248e6a525 by Yufei Cai
Issue #878: Replace WRITE_ALL consistency of topics ddata by optimistic waiting.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/resources/test.conf (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/main/java/org/eclipse/ditto/services/utils/ddata/AkkaReplicatorConfig.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSubImpl.java (diff)
Commit 8c5dfea1accf355749204d098b6a0d32ad1c1f5b by Yufei Cai
Issue #878: update ddata metrics; remove useless params and mocks.

DData topic count metrics replaced by size estimation due to
introduction of literal group names into the ddata of topics
and of declared acknowledgement labels.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt3ClientActorTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/literal/LiteralSubscriptions.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt5ClientActorTest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/Subscriptions.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractSubscriptions.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/ddata/ack/GroupedSnapshot.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/compressed/CompressedSubscriptions.java (diff)
The file was modifiedservices/utils/pubsub/src/test/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractSubscriptionsTest.java (diff)
Commit a7e528d77f364fd44c1b012e302775d1feb364d6 by Yufei Cai
Issue #878: remove unused class LiteralSubscriptions.

Class was used only by an unnecessary interface method.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
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/ddata/literal/LiteralDData.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/actors/SubUpdater.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 removedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/literal/LiteralSubscriptions.java
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/AbstractPubSubFactory.java (diff)
Commit f7ce34b59354bba6e87c838d52bddb84c1d6d5b2 by Yufei Cai
Issue #878: re-introduce diff-based ddata updates.

Akka does not attempt to compute the diff of successive ddata updates,
which is reasonable because Akka does not know that all updates of an
ORSet comes from the same node. Therefore Ditto should compute the diff
so that no unnecessary replication occurs.

Consequently, replicators no longer emits Replicator.Changed events
every update cycle because unchanged subscriptions cause no update.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/literal/LiteralUpdate.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/DDataUpdate.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/ddata/AbstractDDataHandler.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/test/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdaterTest.java (diff)
Commit 492e6026e86596b99883572653457b51e0313905 by Yufei Cai
Issue #878: Make replication delay estimation less pessimistic.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSubImpl.java (diff)
Commit 8baaa7eb590e7d5195fc31bb25dd684c9aceee6a by Yufei Cai
 Issue #878: Make replication delay estimation more pessimistic; fix a double assignment in AckSupervisor.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
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/actors/AckSupervisor.java (diff)
Commit 20c64713f0fbda1fee6ad93facdbeba9c8ca6ff3 by Yufei Cai
Issue #878: [wip] try reverting to write-consistency-based SubAck for topic subscriptions

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSubImpl.java (diff)
Commit 849614de1e632ce55071c2e7fc9c35c295b06899 by Yufei Cai
Issue #878: Move all pubsub-related classes to the same module.

The following modules no longer depends on ditto-services-models-concierge:

- ditto-services-gateway-streaming
- ditto-services-connectivity-messaging

Gateway and connectivity starter modules still depend on concierge service
models because they need ConciergeForwarder.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/starter/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceOperationsActorIT.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ThingEventPubSubFactory.java
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/ProtocolMessageExtractorTest.java (diff)
The file was modifiedservices/gateway/endpoints/pom.xml (diff)
The file was removedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/package-info.java
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/LiveSignalPubSubFactory.java
The file was modifiedservices/concierge/enforcement/src/test/java/org/eclipse/ditto/services/concierge/enforcement/TestSetup.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/LiveSignalPub.java
The file was modifiedservices/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/SearchUpdaterRootActor.java (diff)
The file was modifiedservices/gateway/streaming/src/test/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java (diff)
The file was modifiedservices/gateway/starter/src/main/java/org/eclipse/ditto/services/gateway/starter/GatewayRootActor.java (diff)
The file was modifiedservices/gateway/streaming/src/test/java/org/eclipse/ditto/services/gateway/streaming/StopStreamingTest.java (diff)
The file was modifiedservices/utils/pubsub/pom.xml (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DittoProtocolSubImpl.java
The file was modifiedservices/concierge/enforcement/src/test/java/org/eclipse/ditto/services/concierge/enforcement/LiveSignalEnforcementTest.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DittoProtocolSub.java
The file was removedservices/models/things/src/main/java/org/eclipse/ditto/services/models/things/ThingEventPubSubFactory.java
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebSocketRoute.java (diff)
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/routes/sse/ThingsSseRouteBuilderTest.java (diff)
The file was removedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/streaming/StreamingType.java
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/StreamingAck.java (diff)
The file was modifiedservices/concierge/enforcement/src/main/java/org/eclipse/ditto/services/concierge/enforcement/LiveSignalEnforcement.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/StopStreaming.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/sse/ThingsSseRouteBuilder.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/StartStreaming.java (diff)
The file was modifiedservices/gateway/proxy/pom.xml (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/TestConstants.java (diff)
The file was modifiedservices/gateway/streaming/src/test/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActorHeaderInteractionTest.java (diff)
The file was removedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/LiveSignalPub.java
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/ProtocolMessageExtractor.java (diff)
The file was removedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/streaming/package-info.java
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingActor.java (diff)
The file was modifiedservices/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/AbstractProxyActor.java (diff)
The file was modifiedservices/things/starter/src/main/java/org/eclipse/ditto/services/things/starter/ThingsRootActor.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/ProtocolMessageType.java (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/StreamingType.java
The file was modifiedservices/gateway/streaming/pom.xml (diff)
The file was removedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/LiveSignalPubImpl.java
The file was removedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/DittoProtocolSubImpl.java
The file was removedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/DittoProtocolSub.java
The file was modifiedservices/concierge/starter/src/main/java/org/eclipse/ditto/services/concierge/starter/proxy/DefaultEnforcerActorFactory.java (diff)
The file was removedservices/models/concierge/src/main/java/org/eclipse/ditto/services/models/concierge/pubsub/LiveSignalPubSubFactory.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/SessionedJsonifiable.java (diff)
The file was modifiedservices/connectivity/messaging/pom.xml (diff)
The file was addedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/LiveSignalPubImpl.java
Commit d6b69431d0f3ea6ceac5655215f62de9e33ba4b6 by Yufei Cai
Issue #878: Revert 20c64713; make ddata replication delay more pessimistic.

This reverts commit 20c64713f0fbda1fee6ad93facdbeba9c8ca6ff3.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/DistributedSubImpl.java (diff)
Commit eb84bd4587d4f4d427eff138e5a343f78419be17 by Yufei Cai
Issue #878: Fix handling of Terminated messages by Pub- and AckSupervisor.

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/AckSupervisor.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/actors/ClusterMemberRemovedAware.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/SubSupervisor.java (diff)
Commit dd6b40035755f4fe3d83074e0dbc28c7b1cab162 by Thomas Jaeckle
Issue #878: review: adjusted javadoc in Subscriptions

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/mapping/src/main/java/org/eclipse/ditto/services/connectivity/mapping/ConnectionStatusMessageMapper.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/Subscriptions.java (diff)
Commit d0832f343aa912a74b62efb75ca9d9c788164c5e by Thomas Jaeckle
Issue #878: review: renamed LiteralUpdate.replaceAll method to withInserts; fixed toString()

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/compressed/CompressedSubscriptions.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdater.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/literal/LiteralUpdate.java (diff)
Commit 981d25dfd439ac3626f4ee26312cd8e4b738a8d0 by Thomas Jaeckle
Issue #878: review: fixed calculation of "change" in AbstractSubscriptions
* adjusted Subscribe, AbstractRequest Signatures to accept a Collection instead of a Set in order to make the "topics" guaranteed immutable w/o creating too much Set copies

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/Unsubscribe.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/api/Subscribe.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/api/AbstractRequest.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/ddata/AbstractSubscriptions.java (diff)
Commit d650c64ec3c911b60fcc13ae1646e2218645ff8d by Thomas Jaeckle
fixed logging of exception in AmqpPublisherActor

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActor.java (diff)
Commit ccf29a1dd645b7f62eecb57bda819f885bc79552 by Yufei Cai
Issue #878: replace instance ID by default client ID in BasePublisherActor.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt5PublisherActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt3PublisherActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherErrorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt5ClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/AbstractMqttPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt3ClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPushClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaPublisherActorFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/DefaultKafkaPublisherActorFactory.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BasePublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt3PublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaPublisherActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQPublisherActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQPublisherActor.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/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/kafka/DefaultKafkaPublisherActorFactoryTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt5PublisherActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaClientActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaPublisherActor.java (diff)
Commit 1ba48d1545479a48cf473057f52ea5896b81ecc0 by Yufei Cai
Issue #878: stabilize MQTT client actor tests; remove unused metric.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt5ClientActorTest.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/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt3ClientActorTest.java (diff)
Commit 646261dc09afb4fa1f373f8fb281abbe815e5c89 by Yufei Cai
Issue #878: configure pubsub with a small ddata notify-subscribers-interval for responsiveness.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
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/resources/reference.conf (diff)
Commit f8fb5cf9eb0f8122b93c009cbd9c174cdba23c2d by Thomas Jaeckle
Issue #878: review: removed "final" from interface method

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaPublisherActorFactory.java (diff)
The file was modifiedservices/utils/pubsub/src/main/java/org/eclipse/ditto/services/utils/pubsub/actors/AckUpdater.java (diff)
Commit eff4e45131af3705f7311d9bc9043226c748391f by Thomas Jaeckle
Issue #878: review: replaced "-" separator of connectionId and random UUID for "clientId" with "_" in order to be able to easily split 2 UUIDs

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
Commit 8226882ed546171a65137cec29291f0672b2ea1b by Yufei Cai
Issue #878: Reorder CreateConnection stages to stabilize ConnectionPersistenceActorTest.enabledConnectionLogsAreEnabledAgainAfterModify.

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/strategies/commands/CreateConnectionStrategy.java (diff)