org.turro.mail.impl.MailQueueConsumer Class Reference

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

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

Public Member Functions
void	addToQueue (Collection< MailMessage > pool)
void	addToQueue (Collection< MailMessage > pool, Consumer onFinish)
void	addToQueue (MailMessage mail)
void	addToQueue (MailMessage mail, Consumer onFinish)
int	size ()
void	run ()

Static Public Member Functions
static MailQueueConsumer	getInstance ()
static void	destroy ()

Detailed Description

Author

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

Definition at line 35 of file MailQueueConsumer.java.

Member Function Documentation

addToQueue() [1/4]

void org.turro.mail.impl.MailQueueConsumer.addToQueue

(

Collection< MailMessage >

pool

)

Definition at line 37 of file MailQueueConsumer.java.

                                                       {
    addToQueue(pool, null);
  }

Here is the caller graph for this function:

addToQueue() [2/4]

void org.turro.mail.impl.MailQueueConsumer.addToQueue	(	Collection< MailMessage >	pool,
		Consumer	onFinish
	)

Definition at line 41 of file MailQueueConsumer.java.

                                                                          {
    if(pool == null) return;
    int index = 0, size = pool.size();
    for(MailMessage mail : pool) {
      if(++index == size) {
        addToQueue(mail, onFinish);
      } else {
        addToQueue(mail);
      }
    }
  }

Here is the call graph for this function:

addToQueue() [3/4]

void org.turro.mail.impl.MailQueueConsumer.addToQueue

(

MailMessage

mail

)

Definition at line 53 of file MailQueueConsumer.java.

                                           {
    addToQueue(mail, null);
  }

Here is the call graph for this function:

addToQueue() [4/4]

void org.turro.mail.impl.MailQueueConsumer.addToQueue	(	MailMessage	mail,
		Consumer	onFinish
	)

Definition at line 57 of file MailQueueConsumer.java.

                                                              {
    try {
      if(!QUEUE.offer(new MailQueueItem(mail, onFinish), 60L, TimeUnit.MINUTES)) {
        Logger.getLogger(MailQueueConsumer.class.getName()).log(Level.SEVERE, ElephantContext.logMsg("Too long attempt"));
      }
    } catch (InterruptedException ex) {
      Logger.getLogger(MailQueueConsumer.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
    }
  }

Here is the call graph for this function:

destroy()

static void org.turro.mail.impl.MailQueueConsumer.destroy ( )

static

Definition at line 114 of file MailQueueConsumer.java.

                               {
    if(INSTANCE != null) {
      running.set(false);
      getInstance().addTrigger();
      INSTANCE = null;
    }
  }

Here is the call graph for this function:

Here is the caller graph for this function:

getInstance()

static MailQueueConsumer org.turro.mail.impl.MailQueueConsumer.getInstance ( )

static

Definition at line 105 of file MailQueueConsumer.java.

                                                {
    if(INSTANCE == null) {
      INSTANCE = new MailQueueConsumer();
      MAIL_QUEUE = new Thread(INSTANCE, "ElephantMailQueue");
      MAIL_QUEUE.start();  
    }
    return INSTANCE;
  }

Here is the caller graph for this function:

run()

void org.turro.mail.impl.MailQueueConsumer.run

(

)

Definition at line 77 of file MailQueueConsumer.java.

                    {
    try {
      running.set(true);
      while (running.get()) {
        MailQueueItem item = QUEUE.take();
        if(!running.get()) break;
        try {
          item.send();
        } catch(Exception ex) {
          Logger.getLogger(MailQueueConsumer.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
        }
        Thread.sleep(200);
      }
    } catch (InterruptedException e) {
      Thread.currentThread().interrupt();
    }
  }

Here is the call graph for this function:

size()

int org.turro.mail.impl.MailQueueConsumer.size

(

)

Definition at line 67 of file MailQueueConsumer.java.

                    {
    return QUEUE.size();
  }

Here is the caller graph for this function:

---

The documentation for this class was generated from the following file:

• MailQueueConsumer.java