Inheritance diagram for org.turro.mail.impl.MailMessagePoolSender:

Collaboration diagram for org.turro.mail.impl.MailMessagePoolSender:

Public Member Functions
	MailMessagePoolSender (Set< MailMessage > pool)

void	send (Command onFinish)

void	run ()

Detailed Description

Author: Lluis Turró Cutiller lluis.nosp@m.@tur.nosp@m.ro.or.nosp@m.g

Definition at line 37 of file MailMessagePoolSender.java.

Constructor & Destructor Documentation

◆ MailMessagePoolSender()

org.turro.mail.impl.MailMessagePoolSender.MailMessagePoolSender ( Set< MailMessage > pool )

Definition at line 42 of file MailMessagePoolSender.java.

                                                       {
     this.pool.addAll(pool);
   }

Member Function Documentation

◆ run()

void org.turro.mail.impl.MailMessagePoolSender.run ( )

Definition at line 56 of file MailMessagePoolSender.java.

                     {
     int i = 1, count = pool.size();
     for (MailMessage mail : pool) {
       try {
         mail.send();
         Logger.getLogger(MailMessagePool.class.getName()).log(Level.INFO, "Sent mail from {0} to {1}. Subject: {2}",
             new Object[]{mail.getEmail().getFromAddress().getAddress(),
             InternetAddress.toString((InternetAddress[]) mail.getEmail().getToAddresses().toArray(new InternetAddress[0])), mail.getSubject()});
         if(count > 100 && ++i < count) Thread.sleep(100); // sleep only when using thread
       } catch (MalformedURLException | NamingException | InterruptedException | EmailException ex) {
         Logger.getLogger(MailMessagePool.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
       }
     }
     pool.clear();
     if(onFinish != null) {
       try {
         onFinish.execute(null);
       } catch (Exception ex) {
         Logger.getLogger(MailMessagePool.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
       }
     }
   }

Here is the call graph for this function:

Here is the caller graph for this function:

◆ send()

void org.turro.mail.impl.MailMessagePoolSender.send ( Command onFinish )

Definition at line 46 of file MailMessagePoolSender.java.

                                      {
     this.onFinish = onFinish;
     if(pool.size() > 100) {
       new Thread(this).start();
     } else {
       run();
     }
   }