Skip to content
[Jenkins]Jenkins
log in

Changes

Summary

  1. Add integration tests for MQTT (commit: 01f975e) (details)
  2. Update MqttClientActorIT to test MQTT 3 and 5 (commit: 50e4694) (details)
  3. Refactor (commit: 1921f41) (details)
  4. Use rule instead of before for disabling tracing (commit: eb8755f) (details)
  5. Start mosquitto container via tests (commit: a40a966) (details)
  6. Small improvements to tests (commit: 83762ed) (details)
  7. Run MqttClientActorIT tests for clean session as well (commit: c0e433e) (details)
  8. Small fixes (commit: c8bc6ec) (details)
  9. Fix year in file headers (commit: afeecbc) (details)
  10. Rework consuming messages from MQTT broker (commit: ccee5d1) (details)
  11. Minor changes (commit: 75b60b2) (details)
  12. Add some checks to BufferingFlowableWrapper (commit: 18fbcaa) (details)
  13. Lower visibility of GenericMqttConsumingClient (commit: eaeac18) (details)
  14. Uncomment assertion that all messages aare acked in testMultipleSources (commit: cdbef81) (details)
  15. add "final" to BufferingFlowableWrapper class (commit: 319d385) (details)
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/MqttClientActorIT.java
The file was modified connectivity/service/src/test/resources/test.conf (diff)
Commit 50e46941807dc16048e6eb2381eda4ef227edbc5 by Dmitriy Barbul
Update MqttClientActorIT to test MQTT 3 and 5
 (commit: 50e4694)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/MqttClientActorIT.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/MqttClientActorIT.java (diff)
Commit eb8755ffc4945d8b9306d09a48154aad979fcda1 by Dmitriy Barbul
Use rule instead of before for disabling tracing
 (commit: eb8755f)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/MqttClientActorIT.java (diff)
Commit a40a966073fc00ebf48585143881af4cba432688 by Dmitriy Barbul
Start mosquitto container via tests
 (commit: a40a966)
The file was removedinternal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/mongo/DockerImagePullHandler.java
The file was modified internal/utils/persistence/src/test/java/org/eclipse/ditto/internal/utils/persistence/mongo/indices/IndexInitializerIT.java (diff)
The file was addedinternal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/mosquitto/MosquittoContainerFactory.java
The file was modified thingsearch/service/src/test/java/org/eclipse/ditto/thingsearch/service/persistence/write/mapping/BsonDiffVisitorIT.java (diff)
The file was removedinternal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/mongo/OsDetector.java
The file was addedinternal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/mosquitto/MosquittoResource.java
The file was addedinternal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/DockerContainer.java
The file was modified thingsearch/service/src/test/java/org/eclipse/ditto/thingsearch/service/persistence/write/mapping/BsonDiffVisitorV4IT.java (diff)
The file was addedinternal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/DockerResource.java
The file was modified internal/utils/persistence/src/test/java/org/eclipse/ditto/internal/utils/persistence/mongo/streaming/MongoTimestampPersistenceIT.java (diff)
The file was modified internal/utils/persistence/src/test/java/org/eclipse/ditto/internal/utils/persistence/mongo/streaming/MongoReadJournalIT.java (diff)
The file was addedconnectivity/service/src/test/resources/mosquitto.conf
The file was addedinternal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/DockerImagePullHandler.java
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/MqttClientActorIT.java (diff)
The file was modified thingsearch/service/src/test/java/org/eclipse/ditto/thingsearch/service/persistence/write/mapping/BsonDiffVisitorV5IT.java (diff)
The file was modified internal/utils/persistence/src/test/java/org/eclipse/ditto/internal/utils/persistence/mongo/ops/eventsource/MongoEventSourceITAssertions.java (diff)
The file was addedinternal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/OsDetector.java
The file was modified thingsearch/service/src/test/java/org/eclipse/ditto/thingsearch/service/starter/actors/SearchActorIT.java (diff)
The file was addedinternal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/mongo/MongoContainerFactory.java
The file was modified thingsearch/service/src/test/java/org/eclipse/ditto/thingsearch/service/persistence/AbstractThingSearchPersistenceITBase.java (diff)
The file was removedinternal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/mongo/MongoDbResource.java
The file was removedinternal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/mongo/DockerContainer.java
The file was removedinternal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/mongo/MongoContainerFactory.java
The file was addedinternal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/mongo/MongoDbResource.java
The file was addedinternal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/ContainerFactory.java
The file was modified connectivity/service/src/test/resources/test.conf (diff)
The file was modified internal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/mosquitto/MosquittoContainerFactory.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/MqttClientActorIT.java (diff)
Commit c0e433ec52a0d4c02fb734c0f89999f30c50db5d by Dmitriy Barbul
Run MqttClientActorIT tests for clean session as well
 (commit: c0e433e)
The file was modified connectivity/service/src/test/resources/mosquitto.conf (diff)
The file was modified connectivity/service/src/test/resources/test.conf (diff)
The file was modified internal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/mosquitto/MosquittoContainerFactory.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/MqttClientActorIT.java (diff)
The file was modified internal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/DockerResource.java (diff)
The file was modified internal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/mosquitto/MosquittoContainerFactory.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/MqttClientActorIT.java (diff)
The file was modified internal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/mongo/MongoContainerFactory.java (diff)
The file was modified internal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/ContainerFactory.java (diff)
The file was modified internal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/mosquitto/MosquittoContainerFactory.java (diff)
The file was modified internal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/mongo/MongoContainerFactory.java (diff)
The file was modified internal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/DockerResource.java (diff)
The file was modified internal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/mongo/MongoDbResource.java (diff)
The file was modified internal/utils/test/src/test/java/org/eclipse/ditto/internal/utils/test/docker/mosquitto/MosquittoResource.java (diff)
Commit ccee5d16d37e6cdc3b8f92fd5594cd9d448bcd6c by Dmitriy Barbul
Rework consuming messages from MQTT broker
 (commit: ccee5d1)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/client/Mqtt5RxSubscribingClientTest.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/client/BufferingFlowableWrapper.java
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/client/Mqtt3RxSubscribingClientTest.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/client/GenericMqttConsumingClient.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/client/GenericMqttSubscribingClient.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/client/DefaultGenericMqttClient.java (diff)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/MqttClientActorIT.java (diff)
The file was addedconnectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/client/BaseGenericMqttConsumingClient.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/client/BaseGenericMqttSubscribingClient.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/MqttClientActor.java (diff)
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/client/BufferingFlowableWrapperTest.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/client/BufferingFlowableWrapper.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/client/BaseGenericMqttConsumingClient.java (diff)
The file was addedconnectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/client/BaseGenericMqttConsumingClientTest.java
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/MqttClientActor.java (diff)
Commit 18fbcaa7c1762e87fbb4b651091acc82074c04f1 by Dmitriy Barbul
Add some checks to BufferingFlowableWrapper
 (commit: 18fbcaa)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/client/BufferingFlowableWrapperTest.java (diff)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/client/BufferingFlowableWrapper.java (diff)
Commit eaeac18682a2919f435c6fde96fa6bdb643605fa by Dmitriy Barbul
Lower visibility of GenericMqttConsumingClient
 (commit: eaeac18)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/client/GenericMqttConsumingClient.java (diff)
Commit cdbef810e00f37568dd260c2d989b6766ac8a426 by Dmitriy Barbul
Uncomment assertion that all messages aare acked in testMultipleSources
 (commit: cdbef81)
The file was modified connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/MqttClientActorIT.java (diff)
Commit 319d3855a5bb28360113f3ccb733e3e11693c995 by noreply
add "final" to BufferingFlowableWrapper class
 (commit: 319d385)
The file was modified connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/mqtt/hivemq/client/BufferingFlowableWrapper.java (diff)