org.turro.mail.queue.QueuedSender Class Reference

Inheritance diagram for org.turro.mail.queue.QueuedSender:

Collaboration diagram for org.turro.mail.queue.QueuedSender:

Public Member Functions
	QueuedSender ()
void	send ()
void	pause ()
void	run ()

Static Public Member Functions
static AtomicCounter	getCounter ()

Protected Member Functions
abstract void	doSend ()

Detailed Description

Author

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

Definition at line 32 of file QueuedSender.java.

Constructor & Destructor Documentation

QueuedSender()

org.turro.mail.queue.QueuedSender.QueuedSender

(

)

Definition at line 34 of file QueuedSender.java.

                        {
  }

Member Function Documentation

doSend()

abstract void org.turro.mail.queue.QueuedSender.doSend ( )

abstractprotected

Reimplemented in org.turro.mail.queue.ContactQueueSender, org.turro.publication.util.PublicationNotification, org.turro.newsletter.mail.NewsletterSendToSubscribers, and org.turro.zul.convocation.ConvocationSender.

Here is the caller graph for this function:

getCounter()

static AtomicCounter org.turro.mail.queue.QueuedSender.getCounter ( )

static

Definition at line 78 of file QueuedSender.java.

                                           {
    return openSenders;
  }

pause()

void org.turro.mail.queue.QueuedSender.pause

(

)

Definition at line 44 of file QueuedSender.java.

                      {
    try {
      Thread.sleep(300);
    } catch (InterruptedException ex) {
      Logger.getLogger(QueuedSender.class.getName()).log(Level.SEVERE, ElephantContext.logMsg("Pausing..."), ex);
    }
  }

Here is the call graph for this function:

Here is the caller graph for this function:

run()

void org.turro.mail.queue.QueuedSender.run

(

)

Definition at line 55 of file QueuedSender.java.

                    {
    SENDER_LOCK.lock();
    try {
      openSenders.increment();
      try{
        doSend();
      } catch(Exception ex) {
        Logger.getLogger(QueuedSender.class.getName()).log(Level.SEVERE, ElephantContext.logMsg("Sending..."), ex);
      }
    } finally {
      openSenders.decrement();
      SENDER_LOCK.unlock();
    }
  }

Here is the call graph for this function:

send()

void org.turro.mail.queue.QueuedSender.send

(

)

Definition at line 39 of file QueuedSender.java.

                     {
    Thread sender = new Thread(this, "QueuedSenderTask");
    sender.start();
  }

Here is the caller graph for this function:

---

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

• QueuedSender.java