Subversion Repositories SmartDukaan

Rev

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

Rev 14882 Rev 21881
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 
        //EmailReader pmHelpEmailReader = new EmailReader("help@profitmandi.com", "Help@pm15");
64 
        Folder inbox = helpEmailReader.getInboxFolder();
 64 
        Folder inbox = helpEmailReader.getInboxFolder();
65 
        Folder pmInbox = pmHelpEmailReader.getInboxFolder();
 65 
        //Folder pmInbox = pmHelpEmailReader.getInboxFolder();
66 
        inbox.open(Folder.READ_WRITE);
 66 
        inbox.open(Folder.READ_WRITE);
67 
        pmInbox.open(Folder.READ_WRITE);
 67 
        //pmInbox.open(Folder.READ_WRITE);
68 
        CRMEmailProcessor crmEmailProcessor = new CRMEmailProcessor();
 68 
        CRMEmailProcessor crmEmailProcessor = new CRMEmailProcessor();
69 
 
 69 
 
70 
        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)))
71 
        {
 71 
        {
72 
            boolean isRead = false;
 72 
            boolean isRead = false;
Line 83... Line 83...
83 
                message.setFlags(flags, true);
 83 
                message.setFlags(flags, true);
84 
                message.setFlag(Flags.Flag.SEEN, true);
 84 
                message.setFlag(Flags.Flag.SEEN, true);
85 
            }
 85 
            }
86 
        }
 86 
        }
87
87
88 
        for (Message message : pmInbox.search(new FlagTerm(new Flags(PROCESSED_FLAG), false))){
 88 
        /*for (Message message : pmInbox.search(new FlagTerm(new Flags(PROCESSED_FLAG), false))){
89 
        	boolean isRead = false;
 89 
        	boolean isRead = false;
90 
            try {
 90 
            try {
91 
                log.info("Processing Email from : " + message.getFrom() + "with subject: " + message.getSubject());
 91 
                log.info("Processing Email from : " + message.getFrom() + "with subject: " + message.getSubject());
92 
                isRead = message.getFlags().contains(Flags.Flag.SEEN);
 92 
                isRead = message.getFlags().contains(Flags.Flag.SEEN);
93 
                crmEmailProcessor.processEmail(message);
 93 
                crmEmailProcessor.processEmail(message);
Line 98... Line 98...
98 
                log.error("Could not process message: " + message, e);
 98 
                log.error("Could not process message: " + message, e);
99 
                Flags flags = new Flags(PROCESSED_FLAG);
 99 
                Flags flags = new Flags(PROCESSED_FLAG);
100 
                message.setFlags(flags, true);
 100 
                message.setFlags(flags, true);
101 
                message.setFlag(Flags.Flag.SEEN, true);
 101 
                message.setFlag(Flags.Flag.SEEN, true);
102 
            }
 102 
            }
103 
        }
 103 
        }*/
104 
        log.info("No message left to process, closing Inbox");
 104 
        log.info("No message left to process, closing Inbox");
105 
        inbox.close(false);
 105 
        inbox.close(false);
106 
        pmInbox.close(false);
 106 
        //pmInbox.close(false);
107 
        helpEmailReader.store.close();
 107 
        helpEmailReader.store.close();
108 
        pmHelpEmailReader.store.close();
 108 
        //pmHelpEmailReader.store.close();
109 
    }
 109 
    }
110 
}
 110 
}
111 

            111