SuccessChanges

Summary

  1. Fix topic incremental update bug. (details)
  2. Reset reconnect backoff after successfully establishing a connection (details)
  3. Prevent AmqpClientActor from going into CONNECTED state if message producer cannot be created. (details)
Commit d1497874a4c001a178173cda7a6b7aee0d416a47 by Yufei Cai
Fix topic incremental update bug.

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/actors/SubUpdater.java (diff)
Commit b7c8175d9505e4d5951d4f4358fcd67dcf17fc72 by Yufei Cai
Reset reconnect backoff after successfully establishing a connection

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java (diff)
Commit 66070942a15ec37eeb37c2b116b57ccd1884ecb1 by Yufei Cai
Prevent AmqpClientActor from going into CONNECTED state if message producer cannot be created.

Message consumers are created in JmsConnectionHandlingActor.

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/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/amqp/AmqpPublisherActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActor.java (diff)