Subversion Repositories bacoAlunos

package pt.estgp.estgweb.services.email;

import org.apache.log4j.Logger;
import pt.estgp.estgweb.Globals;
import pt.estgp.estgweb.services.expceptions.ServiceException;
import pt.estgp.estgweb.services.jobs.JobHandler;
import pt.estgp.estgweb.utils.Email;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;

/**
 * @author Jorge Machado
 * @date 11/Jul/2008
 * @see pt.estgp.estgweb.services.sms
 */
public class EMAILJob implements JobHandler, 1.5.0/docs/api/java/io/Serializable.html">Serializable
{
    private static final 1.5.0/docs/api/java/util/logging/Logger.html">Logger logger = 1.5.0/docs/api/java/util/logging/Logger.html">Logger.getLogger(EMAILJob.class);

    private Email email;




    public EMAILJob(Email email)
    {
        this.email = email;
    }




    public void runJob()
    {
        if(Globals.TEST_ENVIRONEMENT && !email.isSystemAssumingTestEmail())
        {
            1.5.0/docs/api/java/lang/String.html">String warn = "System in TEST Environement - will not send EMAIL";
            logger.warn(warn);
            return;
        }
        try
        {
            List<String> recipientsOriginal = new ArrayList<String>();
            List<String> recipients = new ArrayList<String>();
            recipients.addAll(email.getRecipients());
            recipientsOriginal.addAll(email.getRecipients());
            while(recipients.size() > 0)
            {
                List<String> recipientsToSend = new ArrayList<String>();

                int contador = 0;
                Iterator<String> iter = recipients.iterator();
                while(iter.hasNext() && contador < 20)
                {
                    recipientsToSend.add(iter.next());
                    iter.remove();
                    contador++;
                }
                email.setRecipients(recipientsToSend);
                new SendEmailService().sendEmail(email);
                try {
                    1.5.0/docs/api/java/lang/Thread.html">Thread.sleep(1000);
                } catch (1.5.0/docs/api/java/lang/InterruptedException.html">InterruptedException e) {
                    logger.error(e,e);
                }
            }
            try {
                1.5.0/docs/api/java/lang/Thread.html">Thread.sleep(1000);
            } catch (1.5.0/docs/api/java/lang/InterruptedException.html">InterruptedException e) {
                logger.error(e,e);
            }
            email.setRecipients(recipientsOriginal);
        }
        catch (ServiceException e)
        {
            logger.error("Sending EMAIL:" + e.toString(),e);
        }
    }
}