JAMES-2285 Add a MailQueue test for big mail
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/a5f014f2 Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/a5f014f2 Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/a5f014f2 Branch: refs/heads/master Commit: a5f014f2dbe09af1b10a84f47dd65be1113b2a9e Parents: 5b05fde Author: benwa <[email protected]> Authored: Wed Jan 17 17:41:26 2018 +0700 Committer: benwa <[email protected]> Committed: Fri Jan 19 18:57:58 2018 +0700 ---------------------------------------------------------------------- .../james/queue/api/MailQueueContract.java | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/a5f014f2/server/queue/queue-api/src/test/java/org/apache/james/queue/api/MailQueueContract.java ---------------------------------------------------------------------- diff --git a/server/queue/queue-api/src/test/java/org/apache/james/queue/api/MailQueueContract.java b/server/queue/queue-api/src/test/java/org/apache/james/queue/api/MailQueueContract.java index 903bf9e..2d79197 100644 --- a/server/queue/queue-api/src/test/java/org/apache/james/queue/api/MailQueueContract.java +++ b/server/queue/queue-api/src/test/java/org/apache/james/queue/api/MailQueueContract.java @@ -36,6 +36,8 @@ import java.util.concurrent.TimeoutException; import javax.mail.internet.MimeMessage; + +import org.apache.james.core.builder.MimeMessageBuilder; import org.apache.james.junit.ExecutorExtension; import org.apache.mailet.Mail; import org.apache.mailet.PerRecipientHeaders; @@ -43,6 +45,7 @@ import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import com.github.fge.lambdas.Throwing; +import com.google.common.base.Strings; @ExtendWith(ExecutorExtension.class) public interface MailQueueContract { @@ -50,6 +53,22 @@ public interface MailQueueContract { MailQueue getMailQueue(); @Test + default void queueShouldSupportBigMail() throws Exception { + String name = "name1"; + // 12 MB of text + String messageText = Strings.repeat("0123456789\r\n", 1024 * 1024); + getMailQueue().enQueue(defaultMail() + .name(name) + .mimeMessage(MimeMessageBuilder.mimeMessageBuilder() + .setText(messageText)) + .build()); + + MailQueue.MailQueueItem mailQueueItem = getMailQueue().deQueue(); + assertThat(mailQueueItem.getMail().getName()) + .isEqualTo(name); + } + + @Test default void queueShouldPreserveMailRecipients() throws Exception { getMailQueue().enQueue(defaultMail() .recipients(RECIPIENT1, RECIPIENT2) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
