diff --git a/spring-integration-mail/src/main/java/org/springframework/integration/mail/AbstractMailReceiver.java b/spring-integration-mail/src/main/java/org/springframework/integration/mail/AbstractMailReceiver.java index 491dca8cde..2578583c33 100755 --- a/spring-integration-mail/src/main/java/org/springframework/integration/mail/AbstractMailReceiver.java +++ b/spring-integration-mail/src/main/java/org/springframework/integration/mail/AbstractMailReceiver.java @@ -27,6 +27,7 @@ import javax.mail.MessagingException; import javax.mail.Session; import javax.mail.Store; import javax.mail.URLName; +import javax.mail.Flags.Flag; import javax.mail.internet.MimeMessage; import org.apache.commons.logging.Log; @@ -291,7 +292,9 @@ public abstract class AbstractMailReceiver extends IntegrationObjectSupport impl } protected void setAdditionalFlags(Message message) throws MessagingException { - // nothing at the base class + if (this.shouldDeleteMessages) { + message.setFlag(Flag.DELETED, true); + } } void setFolderOpenMode(int folderOpenMode) { diff --git a/spring-integration-mail/src/main/java/org/springframework/integration/mail/ImapMailReceiver.java b/spring-integration-mail/src/main/java/org/springframework/integration/mail/ImapMailReceiver.java index 898204b422..77f51740c8 100755 --- a/spring-integration-mail/src/main/java/org/springframework/integration/mail/ImapMailReceiver.java +++ b/spring-integration-mail/src/main/java/org/springframework/integration/mail/ImapMailReceiver.java @@ -186,6 +186,7 @@ public class ImapMailReceiver extends AbstractMailReceiver { * */ protected void setAdditionalFlags(Message message) throws MessagingException{ + super.setAdditionalFlags(message); if (this.shouldMarkMessagesAsRead) { message.setFlag(Flag.SEEN, true); }