Subversion Repositories SmartDukaan

Rev

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

Rev 7297 Rev 14882
Line 58... Line 58...
58 
     * @throws UserContextException
58 
     * @throws UserContextException
59 
     */
 59 
     */
60 
    public static void main(String[] args) throws MessagingException,
 60 
    public static void main(String[] args) throws MessagingException,
61 
            ParseException, TException, UserContextException {
 61 
            ParseException, TException, UserContextException {
62 
        EmailReader helpEmailReader = new EmailReader("help@shop2020.in", "5h0p2o2o");
 62 
        EmailReader helpEmailReader = new EmailReader("help@shop2020.in", "5h0p2o2o");
- 
 
 63 
        EmailReader pmHelpEmailReader = new EmailReader("help@profitmandi.com", "Help@pm15");
63 
        Folder inbox = helpEmailReader.getInboxFolder();
 64 
        Folder inbox = helpEmailReader.getInboxFolder();
- 
 
 65 
        Folder pmInbox = pmHelpEmailReader.getInboxFolder();
64 
        inbox.open(Folder.READ_WRITE);
 66 
        inbox.open(Folder.READ_WRITE);
- 
 
 67 
        pmInbox.open(Folder.READ_WRITE);
65 
        CRMEmailProcessor crmEmailProcessor = new CRMEmailProcessor();
 68 
        CRMEmailProcessor crmEmailProcessor = new CRMEmailProcessor();
66 
 
 69 
 
67 
        for (Message message : inbox.search(new FlagTerm(new Flags(PROCESSED_FLAG), false)))
 70 
        for (Message message : inbox.search(new FlagTerm(new Flags(PROCESSED_FLAG), false)))
68 
        {
 71 
        {
69 
            boolean isRead = false;
 72 
            boolean isRead = false;
Line 79... Line 82...
79 
                Flags flags = new Flags(PROCESSED_FLAG);
 82 
                Flags flags = new Flags(PROCESSED_FLAG);
80 
                message.setFlags(flags, true);
 83 
                message.setFlags(flags, true);
81 
                message.setFlag(Flags.Flag.SEEN, true);
 84 
                message.setFlag(Flags.Flag.SEEN, true);
82 
            }
 85 
            }
83 
        }
 86 
        }
- 
 
 87
- 
 
 88 
        for (Message message : pmInbox.search(new FlagTerm(new Flags(PROCESSED_FLAG), false))){
- 
 
 89 
        	boolean isRead = false;
- 
 
 90 
            try {
- 
 
 91 
                log.info("Processing Email from : " + message.getFrom() + "with subject: " + message.getSubject());
- 
 
 92 
                isRead = message.getFlags().contains(Flags.Flag.SEEN);
- 
 
 93 
                crmEmailProcessor.processEmail(message);
- 
 
 94 
                Flags flags = new Flags(PROCESSED_FLAG);
- 
 
 95 
                message.setFlags(flags, true);
- 
 
 96 
                message.setFlag(Flags.Flag.SEEN, isRead);
- 
 
 97 
            } catch (Exception e) {
- 
 
 98 
                log.error("Could not process message: " + message, e);
- 
 
 99 
                Flags flags = new Flags(PROCESSED_FLAG);
- 
 
 100 
                message.setFlags(flags, true);
- 
 
 101 
                message.setFlag(Flags.Flag.SEEN, true);
- 
 
 102 
            }
- 
 
 103 
        }
84 
        log.info("No message left to process, closing Inbox");
 104 
        log.info("No message left to process, closing Inbox");
85 
        inbox.close(false);
 105 
        inbox.close(false);
- 
 
 106 
        pmInbox.close(false);
86 
        helpEmailReader.store.close();
 107 
        helpEmailReader.store.close();
- 
 
 108 
        pmHelpEmailReader.store.close();
87 
    }
 109 
    }
88 
}
 110 
}
89 

            111