This is an automated email from the ASF dual-hosted git repository.

btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git

commit c638effd63116e7cda98a7127469ae81f63412b6
Author: LanKhuat <khuatdang...@gmail.com>
AuthorDate: Wed Apr 22 11:05:10 2020 +0700

    JAMES-3143 Add Webadmin integration test
---
 .../RabbitMQWebAdminServerIntegrationTest.java     | 33 ++++++++++++++++++++++
 1 file changed, 33 insertions(+)

diff --git 
a/server/protocols/webadmin-integration-test/distributed-webadmin-integration-test/src/test/java/org/apache/james/webadmin/integration/rabbitmq/RabbitMQWebAdminServerIntegrationTest.java
 
b/server/protocols/webadmin-integration-test/distributed-webadmin-integration-test/src/test/java/org/apache/james/webadmin/integration/rabbitmq/RabbitMQWebAdminServerIntegrationTest.java
index 0f7b1e8..c107aa6 100644
--- 
a/server/protocols/webadmin-integration-test/distributed-webadmin-integration-test/src/test/java/org/apache/james/webadmin/integration/rabbitmq/RabbitMQWebAdminServerIntegrationTest.java
+++ 
b/server/protocols/webadmin-integration-test/distributed-webadmin-integration-test/src/test/java/org/apache/james/webadmin/integration/rabbitmq/RabbitMQWebAdminServerIntegrationTest.java
@@ -199,6 +199,39 @@ class RabbitMQWebAdminServerIntegrationTest extends 
WebAdminServerIntegrationTes
     }
 
     @Test
+    void solveMessageInconsistenciesTasksShouldBeExposed() {
+        String taskId = with().post(UPGRADE_TO_LATEST_VERSION)
+            .jsonPath()
+            .get("taskId");
+
+        with()
+            .get("/tasks/" + taskId + "/await")
+        .then()
+            .body("status", is("completed"));
+
+        taskId = with()
+            .queryParam("task", "SolveInconsistencies")
+            .post("/messages")
+            .jsonPath()
+            .get("taskId");
+
+        given()
+            .basePath(TasksRoutes.BASE)
+        .when()
+            .get(taskId + "/await")
+        .then()
+            .body("status", is("completed"))
+            .body("type", is("solve-message-inconsistencies"))
+            .body("additionalInformation.processedImapUidEntries", is(0))
+            .body("additionalInformation.processedMessageIdEntries", is(0))
+            .body("additionalInformation.addedMessageIdEntries", is(0))
+            .body("additionalInformation.updatedMessageIdEntries", is(0))
+            .body("additionalInformation.removedMessageIdEntries", is(0))
+            .body("additionalInformation.fixedInconsistencies", hasSize(0))
+            .body("additionalInformation.errors", hasSize(0));
+    }
+
+    @Test
     void getSwaggerShouldContainDistributedEndpoints() {
         when()
             .get(SwaggerRoutes.SWAGGER_ENDPOINT)


---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org

Reply via email to