You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by bt...@apache.org on 2019/06/26 03:28:48 UTC
[james-project] 08/28: JAMES-2794 Reprocessing works on top of the
distributed RabbitMQ JAMES
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 <bt...@linagora.com>
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: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org