org.masukomi.aspirin.core.delivery

Class DeliveryManager

java.lang.Object

java.lang.Thread

org.masukomi.aspirin.core.delivery.DeliveryManager

All Implemented Interfaces:

Runnable, ConfigurationChangeListener

public final class DeliveryManager
extends Thread
implements ConfigurationChangeListener

This class is the manager of delivery. It is instantiated by Aspirin class.

Author:

Laszlo Solova

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private Configuration	configuration
private Map<String,DeliveryHandler>	deliveryHandlers
private GenericPoolableDeliveryThreadFactory	deliveryThreadObjectFactory
private org.apache.commons.pool.ObjectPool	deliveryThreadObjectPool
private Helper	helper
private static org.slf4j.Logger	log
private Object	mailingLock
private MailStore	mailStore
private QueueStore	queueStore
private boolean	running

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
DeliveryManager(Configuration configuration, QueueStore queueStore, MailStore mailStore)

Method Summary

Methods

Modifier and Type	Method and Description
String	add(javax.mail.internet.MimeMessage mimeMessage)
void	configChanged(String parameterName) This method is called when a configuration parameter is changed.
javax.mail.internet.MimeMessage	get(QueueInfo qi)
DeliveryHandler	getDeliveryHandler(String handlerName)
boolean	isCompleted(QueueInfo qi)
boolean	isRunning()
void	release(QueueInfo qi)
void	remove(String messageName)
void	run()
void	shutdown()
void	terminate()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

log

private static final org.slf4j.Logger log

configuration

private final Configuration configuration

mailStore

private final MailStore mailStore

queueStore

private final QueueStore queueStore

mailingLock

private Object mailingLock

deliveryThreadObjectPool

private org.apache.commons.pool.ObjectPool deliveryThreadObjectPool

running

private boolean running

deliveryThreadObjectFactory

private GenericPoolableDeliveryThreadFactory deliveryThreadObjectFactory

deliveryHandlers

private Map<String,DeliveryHandler> deliveryHandlers

helper

private final Helper helper

Constructor Detail

DeliveryManager

public DeliveryManager(Configuration configuration,
               QueueStore queueStore,
               MailStore mailStore)

Method Detail

add

public String add(javax.mail.internet.MimeMessage mimeMessage)
           throws javax.mail.MessagingException

Throws:

javax.mail.MessagingException

get

public javax.mail.internet.MimeMessage get(QueueInfo qi)

remove

public void remove(String messageName)

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

isRunning

public boolean isRunning()

terminate

public void terminate()

release

public void release(QueueInfo qi)

isCompleted

public boolean isCompleted(QueueInfo qi)

configChanged

public void configChanged(String parameterName)

Description copied from interface: ConfigurationChangeListener

This method is called when a configuration parameter is changed.

Specified by:

configChanged in interface ConfigurationChangeListener

Parameters:

parameterName - Name of changed parameter.

getDeliveryHandler

public DeliveryHandler getDeliveryHandler(String handlerName)

shutdown

public void shutdown()