Subversion Repositories SmartDukaan

Rev

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

Rev 4537 Rev 7297
Line 64... Line 64...
64 
        inbox.open(Folder.READ_WRITE);
 64 
        inbox.open(Folder.READ_WRITE);
65 
        CRMEmailProcessor crmEmailProcessor = new CRMEmailProcessor();
 65 
        CRMEmailProcessor crmEmailProcessor = new CRMEmailProcessor();
66 
 
 66 
 
67 
        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)))
68 
        {
 68 
        {
- 
 
 69 
            boolean isRead = false;
69 
            try {
 70 
            try {
70 
                log.info("Processing Email from : " + message.getFrom() + "with subject: " + message.getSubject());
 71 
                log.info("Processing Email from : " + message.getFrom() + "with subject: " + message.getSubject());
71 
                boolean isRead = message.getFlags().contains(Flags.Flag.SEEN);
 72 
                isRead = message.getFlags().contains(Flags.Flag.SEEN);
72 
                crmEmailProcessor.processEmail(message);
 73 
                crmEmailProcessor.processEmail(message);
73 
                Flags flags = new Flags(PROCESSED_FLAG);
 74 
                Flags flags = new Flags(PROCESSED_FLAG);
74 
                message.setFlags(flags, true);
 75 
                message.setFlags(flags, true);
75 
                message.setFlag(Flags.Flag.SEEN, isRead);
 76 
                message.setFlag(Flags.Flag.SEEN, isRead);
76 
            } catch (Exception e) {
 77 
            } catch (Exception e) {
77 
                log.error("Could not process message: " + message, e);
 78 
                log.error("Could not process message: " + message, e);
- 
 
 79 
                Flags flags = new Flags(PROCESSED_FLAG);
- 
 
 80 
                message.setFlags(flags, true);
- 
 
 81 
                message.setFlag(Flags.Flag.SEEN, true);
78 
            }
 82 
            }
79 
        }
 83 
        }
80 
        log.info("No message left to process, closing Inbox");
 84 
        log.info("No message left to process, closing Inbox");
81 
        inbox.close(false);
 85 
        inbox.close(false);
82 
        helpEmailReader.store.close();
 86 
        helpEmailReader.store.close();