org.turro.mail.pool.MailQueueConsumer Class Reference

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

Collaboration diagram for org.turro.mail.pool.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 ()
	MailQueueConsumer ()
void	closeElephant ()

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 37 of file MailQueueConsumer.java.

Constructor & Destructor Documentation

MailQueueConsumer()

org.turro.mail.pool.MailQueueConsumer.MailQueueConsumer

(

)

Used by turro-commons reflection

Deprecated:

Use getInstance method instead.

Definition at line 129 of file MailQueueConsumer.java.

                             {
  }

Here is the caller graph for this function:

Member Function Documentation

addToQueue() [1/4]

void org.turro.mail.pool.MailQueueConsumer.addToQueue

(

Collection< MailMessage >

pool

)

Definition at line 39 of file MailQueueConsumer.java.

                                                       {
    addToQueue(pool, null);
  }

Here is the caller graph for this function:

addToQueue() [2/4]

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

Definition at line 43 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.pool.MailQueueConsumer.addToQueue

(

MailMessage

mail

)

Definition at line 55 of file MailQueueConsumer.java.

                                           {
    addToQueue(mail, null);
  }

Here is the call graph for this function:

addToQueue() [4/4]

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

Definition at line 59 of file MailQueueConsumer.java.

                                                              {
    try {
      if(!QUEUE.offer(new MailQueueItem(mail, onFinish), 60L, TimeUnit.MINUTES)) {
        WebLoggers.warning(this).message("Too long attempt").log();
      }
    } catch (InterruptedException ex) {
      WebLoggers.severe(this).exception(ex).log();
    }
  }

Here is the call graph for this function:

closeElephant()

void org.turro.mail.pool.MailQueueConsumer.closeElephant

(

)

Implements org.turro.action.IElephantCloseable.

Definition at line 135 of file MailQueueConsumer.java.

                              {
    MailQueueConsumer.destroy();
  }

Here is the call graph for this function:

destroy()

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

static

Definition at line 116 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.pool.MailQueueConsumer.getInstance ( )

static

Definition at line 107 of file MailQueueConsumer.java.

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

Here is the call graph for this function:

Here is the caller graph for this function:

run()

void org.turro.mail.pool.MailQueueConsumer.run

(

)

Definition at line 79 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) {
          WebLoggers.severe(this).exception(ex).log();
        }
        Thread.sleep(200);
      }
    } catch (InterruptedException e) {
      Thread.currentThread().interrupt();
    }
  }

Here is the call graph for this function:

size()

int org.turro.mail.pool.MailQueueConsumer.size

(

)

Definition at line 69 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