svn commit: r1045109 - /servicemix/components/trunk/bindings/servicemix-mail/src/main/java/org/apache/servicemix/mail/MailPollerEndpoint.java

[gertv]

Author: gertv
Date: Mon Dec 13 13:25:12 2010
New Revision: 1045109

URL: http://svn.apache.org/viewvc?rev=1045109&view=rev
Log:
SMXCOMP-826: in case of a processing error for a mail we set the original mail 
to UNSEEN state just for the case the mail system automatically sets it to SEEN

Modified:
    
servicemix/components/trunk/bindings/servicemix-mail/src/main/java/org/apache/servicemix/mail/MailPollerEndpoint.java

Modified: 
servicemix/components/trunk/bindings/servicemix-mail/src/main/java/org/apache/servicemix/mail/MailPollerEndpoint.java
URL: 
http://svn.apache.org/viewvc/servicemix/components/trunk/bindings/servicemix-mail/src/main/java/org/apache/servicemix/mail/MailPollerEndpoint.java?rev=1045109&r1=1045108&r2=1045109&view=diff
==============================================================================
--- 
servicemix/components/trunk/bindings/servicemix-mail/src/main/java/org/apache/servicemix/mail/MailPollerEndpoint.java
 (original)
+++ 
servicemix/components/trunk/bindings/servicemix-mail/src/main/java/org/apache/servicemix/mail/MailPollerEndpoint.java
 Mon Dec 13 13:25:12 2010
@@ -16,25 +16,33 @@
  */
 package org.apache.servicemix.mail;
 
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.apache.servicemix.common.endpoints.PollingEndpoint;
-import org.apache.servicemix.mail.marshaler.AbstractMailMarshaler;
-import org.apache.servicemix.mail.marshaler.DefaultMailMarshaler;
-import org.apache.servicemix.mail.utils.MailConnectionConfiguration;
-import org.apache.servicemix.mail.utils.MailUtils;
-
+import java.io.IOException;
+import java.util.Collections;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Map;
+import java.util.Properties;
 import javax.jbi.JBIException;
 import javax.jbi.messaging.ExchangeStatus;
 import javax.jbi.messaging.InOnly;
 import javax.jbi.messaging.MessageExchange;
 import javax.jbi.messaging.NormalizedMessage;
-import javax.mail.*;
+import javax.mail.Flags;
+import javax.mail.Folder;
+import javax.mail.Message;
+import javax.mail.Session;
+import javax.mail.Store;
 import javax.mail.internet.MimeMessage;
 import javax.mail.internet.ParseException;
 import javax.mail.search.FlagTerm;
-import java.io.IOException;
-import java.util.*;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.servicemix.common.endpoints.PollingEndpoint;
+import org.apache.servicemix.mail.marshaler.AbstractMailMarshaler;
+import org.apache.servicemix.mail.marshaler.DefaultMailMarshaler;
+import org.apache.servicemix.mail.utils.MailConnectionConfiguration;
+import org.apache.servicemix.mail.utils.MailUtils;
 
 /**
  * This is the polling endpoint for the mail component.
@@ -262,6 +270,11 @@ public class MailPollerEndpoint extends 
 
                     // now check if delivery succeeded or went wrong
                     if (io.getStatus() == ExchangeStatus.ERROR) {
+                        // to ensure reprocessing of the mail we set it to 
UNSEEN even if we
+                        // did not mark it seen before (seems there are some 
mail systems out there
+                        // which do set somehow automatically)
+                        mailMsg.setFlag(Flags.Flag.SEEN, false);
+
                         Exception e = io.getError();
                         if (e == null) {
                             e = new JBIException("Unexpected error 
occured...");