Java EE 6 example source code file (MailServerFolder.java)

This example Java EE 6 source code file (MailServerFolder.java) is included in the DevDaily.com "Java Source Code Warehouse" project. The intent of this project is to help you "Learn Java by Example" ^TM.

Java - Java EE 6 tags/keywords

caught, exception, exception, folder, logging, mailserverfolder, make, make, message, msf, msf, naming, net, network, properties, rmi, string, string, subject, util

The Java EE 6 MailServerFolder.java source code

/*
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
 *
 * Copyright 1997-2009 Sun Microsystems, Inc. All rights reserved.
 *
 * The contents of this file are subject to the terms of either the GNU
 * General Public License Version 2 only ("GPL") or the Common Development
 * and Distribution License("CDDL") (collectively, the "License").  You
 * may not use this file except in compliance with the License. You can obtain
 * a copy of the License at https://glassfish.dev.java.net/public/CDDL+GPL.html
 * or glassfish/bootstrap/legal/LICENSE.txt.  See the License for the specific
 * language governing permissions and limitations under the License.
 *
 * When distributing the software, include this License Header Notice in each
 * file and include the License file at glassfish/bootstrap/legal/LICENSE.txt.
 * Sun designates this particular file as subject to the "Classpath" exception
 * as provided by Sun in the GPL Version 2 section of the License file that
 * accompanied this code.  If applicable, add the following below the License
 * Header, with the fields enclosed by brackets [] replaced by your own
 * identifying information: "Portions Copyrighted [year]
 * [name of copyright owner]"
 *
 * Contributor(s):
 *
 * If you wish your version of this file to be governed by only the CDDL or
 * only the GPL Version 2, indicate your decision by adding "[Contributor]
 * elects to include this software in this distribution under the [CDDL or GPL
 * Version 2] license."  If you don't indicate a single choice of license, a
 * recipient has the option to distribute your version of this file under
 * either the CDDL, the GPL Version 2 or to extend the choice of license to
 * its licensees as provided above.  However, if you add GPL Version 2 code
 * and therefore, elected the GPL Version 2 license, then the option applies
 * only if the new code is made subject to such option by the copyright
 * holder.
 */

package samples.connectors.mailconnector.ra.inbound;

import javax.mail.*;
import javax.mail.event.*;
import javax.mail.internet.*;

import java.util.*;
import java.util.logging.*;
import java.net.*;
import java.io.*;
import java.rmi.*;
import java.rmi.registry.*;
import java.rmi.server.*;
import javax.rmi.*;
import javax.naming.*;

import samples.connectors.mailconnector.ra.*;
//import samples.connectors.mailconnector.ra.outbound.*;
import samples.connectors.mailconnector.share.*;



/**
 * @author Alejandro Murillo
 *
 */

//public class MailServerFolder implements MessageCountListener
public class MailServerFolder
{
    private javax.mail.Session 		session;
    private javax.mail.Authenticator 	authenticator;
    private javax.mail.Store 		store;
    private javax.mail.Folder 		folder;
    private Properties 			mailProperties;

    private String 			folderName, userName, password, 
                  			serverName, protocol;

    public static final Logger logger   = 
        Logger.getLogger("samples.connectors.mailconnector.ra.inbound");


    /**
     * Constructor.
     *
     * @param spec the ActivationSpec for the MDB
     */
    
    public MailServerFolder(ActivationSpecImpl spec)
	throws Exception
    {
	folderName  = spec.getFolderName();
	userName    = spec.getUserName();
	password    = spec.getPassword();
	serverName  = spec.getServerName();
	protocol    = spec.getProtocol();

        this.authenticator = null;

	mailProperties = new Properties();
	mailProperties.setProperty("mail.transport.protocol", "smtp");
	mailProperties.setProperty("mail.store.protocol", protocol);
	mailProperties.setProperty("mail.smtp.host", serverName);
        
        try
        {
            open();
        } catch (Exception te) {
            logger.severe("[S] Caught an exception when opening the " +
                "Folder");
	    //te.printStackTrace();
            throw te;
        }
    }

    /**
     * Closes the folder.
     *
     * @exception Exception if the close fails
     */

    public void close()  
	throws Exception 
    {
         /*
          * The JavaMail Session object does not have an explicit close.  
          */

	 //logger.info("Listener::close()");
         this.store.close();
         this.store = null;
         this.session = null;
         this.authenticator = null;

    }

    /** 
     * Opens a connection to the mail server.
     *
     * @exception Exception  if the open fails
     */

    private void open() 
	throws Exception 
    {
	try
	{
	    // Get a session object
	    session = javax.mail.Session.getDefaultInstance(mailProperties);
	    // Get a store object
	    store = session.getStore();
        } catch (Exception te) {
            logger.info("[MSF] Caught an exception when obtaining a " +
                "JavaMail Session");
	    throw te;
        }

        store.connect(serverName, userName, password);
        folder = store.getFolder(folderName);

        if ((folder == null) || (! this.folder.exists())) 
	{
            Exception e = new Exception("Folder " + folderName +
                " does not exist or is not found");
            throw e;
        }
        
        folder.open(javax.mail.Folder.READ_WRITE);
        //folder.addMessageCountListener(this); //set this as the folder MessageCountListener 
    }

     private void reopen() 
	throws Exception 
    {
        if ( !folder.isOpen() ) 
	{
            //logger.info("[MSF] Reopening folder");
            folder.open(javax.mail.Folder.READ_WRITE);
            //folder.addMessageCountListener(this); //set this as the folder MessageCountListener
        }
    }

    /**
     * Retrieves new messages.
     *
     * @return an array of messages
     */

    public Message[] getNewMessages()
	throws Exception
    {
 	reopen(); //Make sure the folder is open

        //
        // Deliver only new messages to the MDB
        //

	try 
	{
            if (folder.hasNewMessages())
	    {
                int newMsgs    = folder.getNewMessageCount();
	      	int msgCount   = folder.getMessageCount();
	      	Message msgs[] = 
	      	    folder.getMessages(msgCount - newMsgs + 1, msgCount);
	        return msgs;
	    }
        } catch (Exception e) { 
	    logger.info("[MSF] Exception obtaining messages from mail server");
	}
	return null;
    }

    /**
     * Retrieves headers of new messages.
     *
     * @return a string array containing the message headers
     */

    public String[] getNewMessageHeaders()
	throws Exception
    {
        reopen(); //Make sure the folder is open

        //
        // Deliver only new messages to the MDB
        //

	try 
	{	    
	    if (folder.hasNewMessages())
	    {
                int newMsgs    = folder.getNewMessageCount();
	        int msgCount   = folder.getMessageCount();
	      	Message[] msgs = 
	      	    folder.getMessages(msgCount - newMsgs + 1, msgCount);   
	        String[] headers = new String[msgs.length];
		logger.info("messages length: " + msgs.length);
		logger.info("headers length: " + headers.length);
	        for (int i = 0; i < headers.length; i++)
	        {
		    logger.info("[MSF] Packing message with SUBJECT: " +
		        msgs[i].getSubject());
		    headers[i] = msgs[i].getSubject();
	        }
	        return headers;
	    }
        } catch (Exception e) { 
	    logger.severe("[MSF] Exception obtaining messages from mail server:");
            e.printStackTrace(); 
	}
	return null;
    }
      
    public boolean hasNewMessages()
	throws Exception
    {
        reopen(); //Make sure the folder is open

/****
        logger.info("Folder <" + folder.getName() + "> has (" 
                    + folder.getUnreadMessageCount() +  ") unread messages");
        logger.info("Folder <" + folder.getName() + "> has (" 
                    + folder.getNewMessageCount() +  ") NEW messages");
****/

	return  folder.hasNewMessages();
    }
    
    
    /** 
     *  These 2 methods should be uncommented when this class implements
     *  the MessageCountListener interface
     *
     *
    
    public void messagesAdded(MessageCountEvent e) 
    {
        logger.info("messagesAdded: ENTERED");
        try 
	{
            Message[] msgs = e.getMessages();   
            logger.info("messagesAdded: " + msgs.length);
            for (int i = 0; i < msgs.length; i++)
            {
                logger.info("<MSF> Added Message with SUBJECT: " +
		        msgs[i].getSubject());
            }
        } catch (Exception ex) { 
	    logger.info("[S] Got an Exception in messagesAdded");
	}
    }
    
    public void messagesRemoved(MessageCountEvent e) 
    {
        logger.info("messagesRemoved: ENTERED");
        try 
	{
            Message[] msgs = e.getMessages();   
            logger.info("messagesRemoved: " + msgs.length);
            for (int i = 0; i < msgs.length; i++)
            {
                logger.info("<MSF> Removed Message with SUBJECT: " +
		        msgs[i].getSubject());
            }
        } catch (Exception ex) { 
	    logger.info("[S] Got an Exception in messagesRemoved");
	}
    }
     *
     */
    
}