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 e4d5c50ea3dd3d8e1f3c28d97e29a1cdc8b27c83 Author: Benoit Tellier <[email protected]> AuthorDate: Tue Jun 18 12:20:27 2019 +0700 JAMES-2794 Reprocessing works on top of the distributed RabbitMQ JAMES --- .../java/org/apache/james/RabbitMQJamesServerReprocessingTest.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/RabbitMQJamesServerReprocessingTest.java b/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/RabbitMQJamesServerReprocessingTest.java index bc62128..31ec83d 100644 --- a/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/RabbitMQJamesServerReprocessingTest.java +++ b/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/RabbitMQJamesServerReprocessingTest.java @@ -35,7 +35,6 @@ import org.awaitility.Awaitility; import org.awaitility.Duration; import org.awaitility.core.ConditionFactory; import org.junit.jupiter.api.BeforeEach; -import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.RegisterExtension; @@ -69,8 +68,6 @@ class RabbitMQJamesServerReprocessingTest { .paramConfig(new ParamConfig(REPLACE, REPLACE, REPLACE))); } - @Disabled("JAMES-2733 Reprocessing is broken for RabbitMQ mailQueue - the reprocessed mail name is preserved and" + - " is thus considered deleted.") @Test void reprocessingADeniedMailShouldNotLooseIt(GuiceJamesServer server) throws Exception { new SMTPMessageSender("other.com") @@ -86,8 +83,10 @@ class RabbitMQJamesServerReprocessingTest { .jsonPath() .get("taskId"); + // Awaiting the task ensure the reprocessdid start and that the repository was emptied webAdminApi.get("/tasks/" + taskId + "/await"); + // Awaiting that an other mail is present in the mail repository ensures that the reprocessing successfully finished AWAIT.until(() -> mailRepositoryProbe.listMailKeys(SENDER_DENIED).size() == 1); assertThat(mailRepositoryProbe.listMailKeys(SENDER_DENIED)).hasSize(1); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
