| Line 59... |
Line 59... |
| 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 |
Folder inbox = new EmailReader("help@shop2020.in", "5h0p2o2o").getInboxFolder();
|
62 |
Folder inbox = new EmailReader("help@shop2020.in", "5h0p2o2o").getInboxFolder();
|
| 63 |
inbox.open(Folder.READ_ONLY);
|
63 |
inbox.open(Folder.READ_ONLY);
|
| 64 |
Date lastReceivedEmailTimestamp = null;
|
- |
|
| 65 |
CRMEmailProcessor crmEmailProcessor = new CRMEmailProcessor();
|
64 |
CRMEmailProcessor crmEmailProcessor = new CRMEmailProcessor();
|
| - |
|
65 |
Date lastProcessedEmailTimestamp = crmEmailProcessor.getLastProcessedTimestamp();
|
| - |
|
66 |
Date lastReceivedEmailTimestamp = lastProcessedEmailTimestamp;
|
| - |
|
67 |
|
| 66 |
for (Message message : inbox.search(new ReceivedDateTerm(
|
68 |
for (Message message : inbox.search(new ReceivedDateTerm(
|
| 67 |
ComparisonTerm.GE, crmEmailProcessor.getLastProcessedTimestamp())))
|
69 |
ComparisonTerm.GE, lastProcessedEmailTimestamp)))
|
| 68 |
{
|
70 |
{
|
| 69 |
try {
|
71 |
try {
|
| - |
|
72 |
// Skipping mails received before the last processed timestamp
|
| - |
|
73 |
if (!lastProcessedEmailTimestamp.before(message.getReceivedDate())) {
|
| - |
|
74 |
continue;
|
| - |
|
75 |
}
|
| - |
|
76 |
|
| 70 |
lastReceivedEmailTimestamp = message.getReceivedDate();
|
77 |
lastReceivedEmailTimestamp = message.getReceivedDate();
|
| 71 |
crmEmailProcessor.processEmail(message);
|
78 |
crmEmailProcessor.processEmail(message);
|
| 72 |
} catch (IOException e) {
|
79 |
} catch (IOException e) {
|
| 73 |
log.error("Could not process message: " + message, e);
|
80 |
log.error("Could not process message: " + message, e);
|
| 74 |
} catch (TException e) {
|
81 |
} catch (TException e) {
|