diff --git a/src/dps-email-poller/src/main/java/ca/bc/gov/open/pssg/rsbc/dps/dpsemailpoller/scheduler/EmailPoller.java b/src/dps-email-poller/src/main/java/ca/bc/gov/open/pssg/rsbc/dps/dpsemailpoller/scheduler/EmailPoller.java index ee1c62c0..e9c5df60 100644 --- a/src/dps-email-poller/src/main/java/ca/bc/gov/open/pssg/rsbc/dps/dpsemailpoller/scheduler/EmailPoller.java +++ b/src/dps-email-poller/src/main/java/ca/bc/gov/open/pssg/rsbc/dps/dpsemailpoller/scheduler/EmailPoller.java @@ -82,10 +82,12 @@ public void pollForEmails() { logger.debug("attempting to retrieve email attachments"); List fileAttachments = emailService.getFileAttachments(item.getId().getUniqueId()); logger.info("successfully retrieved {} attachments", fileAttachments.size()); + logMemory(); Optional attachment = fileAttachments.stream().findFirst(); if (!attachment.isPresent()) throw new DpsEmailException("No attachment present in email."); + logMemory(); logger.debug("attempting to store email attachment"); String fileId = this.storageService.put(attachment.get().getContent()); @@ -103,6 +105,7 @@ public void pollForEmails() { MDC.put(MdcConstants.MDC_TRANSACTION_ID_KEY, metadata.getTransactionId().toString()); logger.info("successfully parsed email content"); + logMemory(); EmailMessage processedItem = emailService.moveToProcessingFolder(item.getId().getUniqueId()); metadata.setEmailId(processedItem.getId().getUniqueId());