Subversion Repositories SmartDukaan

Rev

Rev 4523 | Rev 4537 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 4523 Rev 4536
Line 3... Line 3...
3 
 */
 3 
 */
4 
package in.shop2020.util;
 4 
package in.shop2020.util;
5 
 
 5 
 
6 
import in.shop2020.model.v1.user.UserContextException;
 6 
import in.shop2020.model.v1.user.UserContextException;
7 
 
 7 
 
8 
import java.io.IOException;
 - 
 
9 
import java.text.ParseException;
 8 
import java.text.ParseException;
10 
import java.util.Date;
 - 
 
11 
import java.util.Properties;
 9 
import java.util.Properties;
12 
 
 10 
 
13 
import javax.mail.Flags;
 11 
import javax.mail.Flags;
14 
import javax.mail.Flags.Flag;
 - 
 
15 
import javax.mail.Folder;
 12 
import javax.mail.Folder;
16 
import javax.mail.Message;
 13 
import javax.mail.Message;
17 
import javax.mail.MessagingException;
 14 
import javax.mail.MessagingException;
18 
import javax.mail.NoSuchProviderException;
 15 
import javax.mail.NoSuchProviderException;
19 
import javax.mail.Session;
 16 
import javax.mail.Session;
20 
import javax.mail.Store;
 17 
import javax.mail.Store;
21 
import javax.mail.search.ComparisonTerm;
 - 
 
22 
import javax.mail.search.FlagTerm;
 18 
import javax.mail.search.FlagTerm;
23 
import javax.mail.search.ReceivedDateTerm;
 - 
 
24 
 
 19 
 
25 
import org.apache.commons.logging.Log;
 20 
import org.apache.commons.logging.Log;
26 
import org.apache.commons.logging.LogFactory;
 21 
import org.apache.commons.logging.LogFactory;
27 
import org.apache.thrift.TException;
 22 
import org.apache.thrift.TException;
28 
 
 23 
 
Line 71... Line 66...
71 
 
 66 
 
72 
        for (Message message : inbox.search(new FlagTerm(new Flags(PROCESSED_FLAG), false)))
 67 
        for (Message message : inbox.search(new FlagTerm(new Flags(PROCESSED_FLAG), false)))
73 
        {
 68 
        {
74 
            try {
 69 
            try {
75 
                log.info("Processing Email from : " + message.getFrom() + "with subject: " + message.getSubject());
 70 
                log.info("Processing Email from : " + message.getFrom() + "with subject: " + message.getSubject());
- 
 
 71 
                boolean isRead = false;
- 
 
 72 
                if (message.getFlags().contains(Flags.Flag.SEEN)) {
- 
 
 73 
                    isRead = true;
- 
 
 74 
                }
76 
                crmEmailProcessor.processEmail(message);
 75 
                crmEmailProcessor.processEmail(message);
77 
                Flags flags = new Flags(PROCESSED_FLAG);
 76 
                Flags flags = new Flags(PROCESSED_FLAG);
78 
                message.setFlags(flags, true);
 77 
                message.setFlags(flags, true);
79 
                if (message.getFlags().contains(Flags.Flag.SEEN)) {
 - 
 
80 
                    message.setFlag(Flags.Flag.SEEN, true);
 78 
                message.setFlag(Flags.Flag.SEEN, isRead);
81 
                } else {
 - 
 
82 
                    message.setFlag(Flags.Flag.SEEN, false);
 - 
 
83 
                }
 - 
 
84 
            } catch (Exception e) {
 79 
            } catch (Exception e) {
85 
                log.error("Could not process message: " + message, e);
 80 
                log.error("Could not process message: " + message, e);
86 
            }
 81 
            }
87 
        }
 82 
        }
88 
        log.info("No message left to process, closing Inbox");
 83 
        log.info("No message left to process, closing Inbox");