SuccessChanges

Summary

  1. Integrate DittoMetrics into ConnectivityCounters (details)
  2. Measure time of http request in HttpPublisherActor (details)
  3. Preserve materialized value of the given flow to measure the time for (details)
  4. Reset reconnect backoff after successfully establishing a connection (details)
  5. Improved error description for too many outgoing messages for amqp and http (details)
  6. Add logging for each http request time (details)
  7. add/fix javadoc and imports (details)
  8. change year to 2021 license-header to fix check (details)
Commit 7ac6b6cc87acc0c76a0aa705da9d000acb99f4ae by Yannic Klem
Integrate DittoMetrics into ConnectivityCounters

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt3ConsumerActor.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/monitoring/metrics/DefaultConnectionMetricsCounter.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/TestConstants.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/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActorTest.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/test/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/metrics/DefaultConnectionMetricsCounterTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/OutboundMappingProcessorActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/SignalFilter.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/amqp/AmqpConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/ConnectionLoggerRegistryTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/metrics/ConnectivityCounterRegistryTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/DefaultConnectionMonitorRegistry.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/AbstractMqttConsumerActor.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/test/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt5ConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt3ConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/metrics/SlidingWindowCounter.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/ConnectionLoggerRegistry.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/metrics/ConnectivityCounterRegistry.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/rabbitmq/RabbitMQConsumerActorTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/mqtt/hivemq/HiveMqtt5ConsumerActor.java (diff)
The file was modifiedservices/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/metrics/SlidingWindowCounterTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/ConnectionMonitorRegistry.java (diff)
Commit b65d6bcf3e94922f77dd6797a84beb006a70e403 by Yannic Klem
Measure time of http request in HttpPublisherActor

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was addedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/controlflow/TimeMeasuringFlow.java
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherActor.java (diff)
The file was addedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/controlflow/TimeMeasuringFlowTest.java
Commit 3803ca202eef75d2473a6fe82100a2f14ed621d7 by Yannic Klem
Preserve materialized value of the given flow to measure the time for

* Also removed an unnecessary flow and replaced it by directly connecting
  to the broadcast inlets.
* Also explcitly connected beforeTimerBroadcast.out(0) with start timer flow
  and out(1) with the flow to measure.
** This causes the timer to be started before the flow to measure.

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/controlflow/TimeMeasuringFlow.java (diff)
Commit 9c40851033e15e003006126494a1f506c127bd11 by Yannic Klem
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 3427a3cb8e9b068a0d4710825122dcbc11dc07d1 by Yannic Klem
Improved error description for too many outgoing messages for amqp and http

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
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/amqp/AmqpPublisherActor.java (diff)
Commit 4238d3166f41a9baf5c110a317937319294101e9 by Yannic Klem
Add logging for each http request time

* This allows a user to see how much time the HTTP requests take

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/controlflow/TimeMeasuringFlow.java (diff)
The file was modifiedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/controlflow/TimeMeasuringFlowTest.java (diff)
The file was modifiedservices/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/httppush/HttpPublisherActor.java (diff)
Commit 4a5108cb97533d90428d07431d4b9bc6bce207ee by joel.bartelheimer
add/fix javadoc and imports

Signed-off-by: Joel Bartelheimer <joel.bartelheimer@bosch.io>
The file was modifiedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/controlflow/TimeMeasuringFlowTest.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/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/controlflow/TimeMeasuringFlow.java (diff)
Commit 553fc772c68ecb50c5bc9faaf4145326b8fc5d1b by joel.bartelheimer
change year to 2021 license-header to fix check

Signed-off-by: Joel Bartelheimer <joel.bartelheimer@bosch.io>
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/controlflow/TimeMeasuringFlow.java (diff)
The file was modifiedservices/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/controlflow/TimeMeasuringFlowTest.java (diff)