Java Batch To Read Mailbox And Fetch The Mail Contents

[murali jackson]

Hi All,

I am trying to design a Java Batch program which will monitor a particular mailbox in MS outlook , and if a new mail is received it should process the mail
and fetch the attachment which is an excel sheet and process the content of the excel sheet and load it to MSSQL database.

I know how to process Excel using java but confused on which design or API I need to use for monitoring mailbox.
Could you please share some high level idea on this... Thanks !!!

[Tim Moores]

The API for handling mail is called JavaMail. I suggest to start with familiarizing yourself with that: how to access mail, how to retrieve new mail, how to determine which messages have attachments etc. Only then add handling of attachments (how that's done has nothing to do with mail processing as such).

[murali jackson]

Thanks Tim !!!
I will check this API and post here if i have any further doubt...

[murali jackson]

I have googled about Java mail API and used below sample code to connect to my outlook mailbox but it is showing connection failed.
Dont know whether im passing the parameters wrongly. Im sure that my username and password is correct.

Please throw some light on this.

public class ReceiveEmailWithAttachment { 
	 private String saveDirectory;

	    public void downloadEmailAttachments(String host, String port,
	            String userName, String password) throws MessagingException {
	        Properties properties = new Properties();
	 
	        // server setting
	        properties.put("mail.pop3.host", host);
	        properties.put("mail.pop3.port", port);
	 
	        // SSL setting
	        properties.setProperty("mail.pop3.socketFactory.class",
	                "javax.net.ssl.SSLSocketFactory");
	        properties.setProperty("mail.pop3.socketFactory.fallback", "false");
	        properties.setProperty("mail.pop3.socketFactory.port",
	                String.valueOf(port));
	 
	        Session session = Session.getDefaultInstance(properties);
	 
	 
	            // connects to the message store
	            Store store = session.getStore("pop3");
	            store.connect(userName, password);
	    }
	 
	 
	    /**
	     * Runs this program with Gmail POP3 server
	     * @throws MessagingException 
	     */
	    public static void main(String[] args) throws MessagingException {
	        String host = "MailHost.company.com"; //changed 
	        String port = "995";
	        String userName = "[e-mail]"; //changed
	        String password = "password"; //changed
	 
	        
	 
	        ReceiveEmailWithAttachment receiver = new ReceiveEmailWithAttachment();
	        
	        receiver.downloadEmailAttachments(host, port, userName, password);
	 
	    }
}

Error is below :

javax.mail.MessagingException: Connect failed;
  nested exception is:
	java.net.SocketException: Operation timed out: connect:could be due to invalid address
	at com.sun.mail.pop3.POP3Store.protocolConnect(POP3Store.java:210)
	at javax.mail.Service.connect(Service.java:295)
	at javax.mail.Service.connect(Service.java:176)
	at javax.mail.Service.connect(Service.java:196)
	at com.mail.send.ReceiveEmailWithAttachment.downloadEmailAttachments(ReceiveEmailWithAttachment.java:59)
	at com.mail.send.ReceiveEmailWithAttachment.main(ReceiveEmailWithAttachment.java:145)
Caused by: java.net.SocketException: Operation timed out: connect:could be due to invalid addressCould not connect to the message store

	at java.net.PlainSocketImpl.socketConnect(Native Method)
	at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:391)
	at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:252)
	at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:239)
	at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:385)
	at java.net.Socket.connect(Socket.java:543)
	at com.ibm.jsse2.jc.connect(jc.java:68)
	at com.ibm.jsse2.ic.connect(ic.java:74)
	at com.sun.mail.util.SocketFetcher.createSocket(SocketFetcher.java:288)
	at com.sun.mail.util.SocketFetcher.getSocket(SocketFetcher.java:205)
	at com.sun.mail.pop3.Protocol.<init>(Protocol.java:107)
	at com.sun.mail.pop3.POP3Store.getPort(POP3Store.java:261)
	at com.sun.mail.pop3.POP3Store.protocolConnect(POP3Store.java:206)
	... 5 more

[Tony Docherty]

It's a long time since I used JavaMail so I'm a bit rusty but the code looks ok to me.

The exception says it can't connect to the message store due to an invalid address so I'd check the host address you are using.

[murali jackson]

Hi ,

Now Im able to connect to the host but its throwing certificate chaining error.
When I googled about this error, suggestions was like i need to import certificates to my WAS server.
But this is standalone application which i have not published to any server. So don't know how to proceed.
Please advise.

package com.mail.reader;

import java.io.IOException;
import java.util.Properties;

import javax.mail.Folder;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.NoSuchProviderException;
import javax.mail.PasswordAuthentication;
import javax.mail.Session;
import javax.mail.Store;

import com.sun.mail.pop3.POP3Store;

public class OutlookReader {

	public static void main(String[] args) throws MessagingException, IOException {
		// TODO Auto-generated method stub


		String host = "10.24.29.172";
		String mailStoreType="imap";
		String username = "[e-mail]";
		String password = "password";
		
		
		
		
		receiveEmail(host, mailStoreType, username, password);  
		
		

	}

	private static void receiveEmail(String host, String mailStoreType, String username, String password) throws MessagingException, IOException {
		// TODO Auto-generated method stub
		
	      Properties properties = new Properties();

	     
	      properties.setProperty("mail.store.protocol", "imap");
	      properties.setProperty("mail.imap.user","[e-mail]");
	      properties.setProperty("mail.imap.host", "10.24.29.172");
	      properties.put("mail.imap.starttls.enable", "false");
	      properties.setProperty("mail.imap.port", "993");
	      //Session emailSession = Session.getDefaultInstance(properties);
	      Session emailSession = Session.getInstance(properties, new javax.mail.Authenticator() {
	    	    protected PasswordAuthentication getPasswordAuthentication() {
	    	        return new PasswordAuthentication("[e-mail]", "password");
	    	    }
	    	});
	      
	      System.out.println("1");
	       
	      Store store = emailSession.getStore("imaps");
	      System.out.println("2");
	      store.connect(host, username, password);
	      System.out.println("3");
	      Folder emailFolder = store.getFolder("INBOX");
	      emailFolder.open(Folder.READ_ONLY);
		   //4) retrieve the messages from the folder in an array and print it  
		   Message[] messages = emailFolder.getMessages();  
		   for (int i = 0; i < messages.length; i++) {  
		    Message message = messages[i];  
		    System.out.println("---------------------------------");  
		    System.out.println("Email Number " + (i + 1));  
		    System.out.println("Subject: " + message.getSubject());  
		    System.out.println("From: " + message.getFrom()[0]);  
		    System.out.println("Text: " + message.getContent().toString());  
		   }  
		   
		   
		
	}

}

Error is below

1
2
Exception in thread "main" javax.mail.MessagingException: com.ibm.jsse2.util.j: PKIX path building failed: java.security.cert.CertPathBuilderException: PKIXCertPathBuilderImpl could not build a valid CertPath.; internal caAPe is: 
	java.security.cert.CertPathValidatorException: The certificate issued by CN=CompanyRootCA2015, O=Company, C=AP is not trAPted; internal caAPe is: 
	java.security.cert.CertPathValidatorException: Certificate chaining error;
  nested exception is:
	javax.net.ssl.SSLHandshakeException: com.ibm.jsse2.util.j: PKIX path building failed: java.security.cert.CertPathBuilderException: PKIXCertPathBuilderImpl could not build a valid CertPath.; internal caAPe is: 
	java.security.cert.CertPathValidatorException: The certificate issued by CN=CompanyRootCA2015, O=Company, C=AP is not trAPted; internal caAPe is: 
	java.security.cert.CertPathValidatorException: Certificate chaining error
	at com.sun.mail.imap.IMAPStore.protocolConnect(IMAPStore.java:665)
	at javax.mail.Service.connect(Service.java:295)
	at javax.mail.Service.connect(Service.java:176)
	at com.mail.reader.OutlookReader.receiveEmail(OutlookReader.java:58)
	at com.mail.reader.OutlookReader.main(OutlookReader.java:30)
CaAPed by: javax.net.ssl.SSLHandshakeException: com.ibm.jsse2.util.j: PKIX path building failed: java.security.cert.CertPathBuilderException: PKIXCertPathBuilderImpl could not build a valid CertPath.; internal caAPe is: 
	java.security.cert.CertPathValidatorException: The certificate issued by CN=CompanyRootCA2015, O=Company, C=AP is not trAPted; internal caAPe is: 
	java.security.cert.CertPathValidatorException: Certificate chaining error
	at com.ibm.jsse2.o.a(o.java:44)
	at com.ibm.jsse2.SSLSocketImpl.a(SSLSocketImpl.java:723)
	at com.ibm.jsse2.kb.a(kb.java:70)
	at com.ibm.jsse2.kb.a(kb.java:192)
	at com.ibm.jsse2.lb.a(lb.java:333)
	at com.ibm.jsse2.lb.a(lb.java:133)
	at com.ibm.jsse2.kb.s(kb.java:45)
	at com.ibm.jsse2.kb.a(kb.java:306)
	at com.ibm.jsse2.SSLSocketImpl.a(SSLSocketImpl.java:421)
	at com.ibm.jsse2.SSLSocketImpl.h(SSLSocketImpl.java:254)
	at com.ibm.jsse2.SSLSocketImpl.a(SSLSocketImpl.java:525)
	at com.ibm.jsse2.SSLSocketImpl.startHandshake(SSLSocketImpl.java:790)
	at com.sun.mail.util.SocketFetcher.configureSSLSocket(SocketFetcher.java:507)
	at com.sun.mail.util.SocketFetcher.getSocket(SocketFetcher.java:238)
	at com.sun.mail.iap.Protocol.<init>(Protocol.java:113)
	at com.sun.mail.imap.protocol.IMAPProtocol.<init>(IMAPProtocol.java:110)
	at com.sun.mail.imap.IMAPStore.protocolConnect(IMAPStore.java:632)
	... 4 more
CaAPed by: com.ibm.jsse2.util.j: PKIX path building failed: java.security.cert.CertPathBuilderException: PKIXCertPathBuilderImpl could not build a valid CertPath.; internal caAPe is: 
	java.security.cert.CertPathValidatorException: The certificate issued by CN=CompanyRootCA2015, O=Company, C=AP is not trAPted; internal caAPe is: 
	java.security.cert.CertPathValidatorException: Certificate chaining error
	at com.ibm.jsse2.util.h.b(h.java:40)
	at com.ibm.jsse2.util.h.b(h.java:7)
	at com.ibm.jsse2.util.g.a(g.java:11)
	at com.ibm.jsse2.pc.a(pc.java:22)
	at com.ibm.jsse2.pc.checkServerTrAPted(pc.java:94)
	at com.ibm.jsse2.pc.b(pc.java:103)
	at com.ibm.jsse2.lb.a(lb.java:512)
	... 16 more
CaAPed by: java.security.cert.CertPathBuilderException: PKIXCertPathBuilderImpl could not build a valid CertPath.; internal caAPe is: 
	java.security.cert.CertPathValidatorException: The certificate issued by CN=CompanyRootCA2015, O=Company, C=AP is not trAPted; internal caAPe is: 
	java.security.cert.CertPathValidatorException: Certificate chaining error
	at com.ibm.security.cert.PKIXCertPathBuilderImpl.engineBuild(PKIXCertPathBuilderImpl.java:411)
	at java.security.cert.CertPathBuilder.build(CertPathBuilder.java:258)
	at com.ibm.jsse2.util.h.b(h.java:55)
	... 22 more
CaAPed by: java.security.cert.CertPathValidatorException: The certificate issued by CN=CompanyRootCA2015, O=Company, C=AP is not trAPted; internal caAPe is: 
	java.security.cert.CertPathValidatorException: Certificate chaining error
	at com.ibm.security.cert.BasicChecker.<init>(BasicChecker.java:111)
	at com.ibm.security.cert.PKIXCertPathValidatorImpl.engineValidate(PKIXCertPathValidatorImpl.java:178)
	at com.ibm.security.cert.PKIXCertPathBuilderImpl.myValidator(PKIXCertPathBuilderImpl.java:737)
	at com.ibm.security.cert.PKIXCertPathBuilderImpl.buildCertPath(PKIXCertPathBuilderImpl.java:649)
	at com.ibm.security.cert.PKIXCertPathBuilderImpl.buildCertPath(PKIXCertPathBuilderImpl.java:595)
	at com.ibm.security.cert.PKIXCertPathBuilderImpl.engineBuild(PKIXCertPathBuilderImpl.java:357)
	... 24 more
CaAPed by: java.security.cert.CertPathValidatorException: Certificate chaining error
	at com.ibm.security.cert.CertPathUtil.findIssuer(CertPathUtil.java:298)
	at com.ibm.security.cert.BasicChecker.<init>(BasicChecker.java:108)
	... 29 more