SuccessChanges

Summary

  1. Extract RequestedAcksFilter from InboundDispatchingActor; switch to external message dispatcher. (details)
  2. Fix TODO; replace redundant conditional; adjust format. (details)
  3. review: some minor cosmetic changes (details)
Commit eafbfd095c4e2a3896b99299f62ff943201894aa by Yufei Cai
Extract RequestedAcksFilter from InboundDispatchingActor; switch to external message dispatcher.

Reason: typical QoS headers are available in external message headers
and not in the signal headers.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundDispatchingActor.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/RequestedAcksFilter.java
The file was addedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/RequestedAcksFilterTest.java
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActorTest.java (diff)
Commit 530281f1425cd25c66034bab469ee1b68de0c3cc by Yufei Cai
Fix TODO; replace redundant conditional; adjust format.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/InboundMappingProcessor.java (diff)
Commit 3473b028ae138ead457eae6c7ffa6818fa01b805 by Thomas Jaeckle
review: some minor cosmetic changes

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@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/RequestedAcksFilter.java (diff)
The file was modifiedmodel/connectivity/src/main/java/org/eclipse/ditto/model/connectivity/ImmutableLogEntry.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/RequestedAcksFilterTest.java (diff)