FailedChanges

Summary

  1. Wrap sending the Amqp messages in a stream with a preceding queue/buffer (details)
  2. Add tests for new introduced publisher-queue (details)
  3. Add JavaDocs and some minor refactorings of the newly integrated pusblisher-queue (details)
  4. Add the new config values to the new config tests, which were introduced in the last merge (details)
  5. AmqpPublisherActorTest: Prevent test failure due to low timeout. (details)
  6. Review: AmqpPublisherActor: move non-thread-safe producer lookup to the actor's thread; format code; fix comment; do not request ack for the congesting messages in AmqpPublisherActorTest. (details)
Commit 9df2a68cb537e077196674f1d176577e0aa155a0 by joel.bartelheimer
Wrap sending the Amqp messages in a stream with a preceding queue/buffer

The queue infront of the amqp-send-msg stage, drops messages if the queue is full. This prevent an overflow of the actor mailbox if the consumer isn't fast enough or doesn't consume at all.

Signed-off-by: Joel Bartelheimer <joel.bartelheimer@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/Amqp10Config.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultAmqp10Config.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpPublisherActor.java (diff)
The file was addedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpMessageContext.java
Commit 3355fea7df74cc033ed1e5961e0f03c010180e87 by joel.bartelheimer
Add tests for new introduced publisher-queue

also adapted the config to the introduced properties

Signed-off-by: Joel Bartelheimer <joel.bartelheimer@bosch.io>
The file was modifiedservices/connectivity/starter/src/main/resources/connectivity.conf (diff)
The file was modifiedservices/connectivity/messaging/src/test/resources/test.conf (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/config/Amqp10Config.java (diff)
Commit 030c1820cd419f59ae28d6b1e839c059b4835b57 by joel.bartelheimer
Add JavaDocs and some minor refactorings of the newly integrated pusblisher-queue

Signed-off-by: Joel Bartelheimer <joel.bartelheimer@bosch.io>
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/AmqpMessageContext.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/Amqp10Config.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/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultAmqp10Config.java (diff)
Commit 67a1272a26cd13c93c5aa35af9790a79f7b8be6e by joel.bartelheimer
Add the new config values to the new config tests, which were introduced in the last merge

Signed-off-by: Joel Bartelheimer <joel.bartelheimer@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultAmqp10ConfigTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/resources/amqp10-test.conf (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/config/DefaultAmqp10Config.java (diff)
Commit 71526892e43f13158ca47f344042394cd5bcff61 by Yufei Cai
AmqpPublisherActorTest: Prevent test failure due to low timeout.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
The file was modifiedservices/connectivity/messaging/src/test/resources/test.conf (diff)
Commit 3d089e333ca4f5dc54798c8a3432517f19f465d8 by Yufei Cai
Review: AmqpPublisherActor: move non-thread-safe producer lookup to the actor's thread; format code; fix comment; do not request ack for the congesting messages in AmqpPublisherActorTest.

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/AmqpPublisherActor.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/starter/src/main/resources/connectivity.conf (diff)