org.apache.james.mailetcontainer.impl

Class JamesMailSpooler

java.lang.Object

org.apache.james.mailetcontainer.impl.JamesMailSpooler

All Implemented Interfaces:

Runnable, Configurable, LogEnabled, MailSpoolerMBean

public class JamesMailSpooler
extends Object
implements Runnable, Configurable, LogEnabled, MailSpoolerMBean

Manages the mail spool. This class is responsible for retrieving messages from the spool, directing messages to the appropriate processor, and removing them from the spool when processing is complete.

Constructor Summary

Constructors

Constructor and Description
JamesMailSpooler()

Method Summary

Methods

Modifier and Type	Method and Description
void	configure(org.apache.commons.configuration.HierarchicalConfiguration config) Configure the object.
void	dispose() The dispose operation is called at the end of a components lifecycle.
int	getCurrentSpoolCount()
int	getThreadCount() Return the number of threads used for spooling
void	init() Initializes the spool manager.
void	run() This routinely checks the message spool for messages, and processes them as necessary
void	setLog(org.slf4j.Logger log) Sets the service log.
void	setMailProcessor(MailProcessor mailProcessor)
void	setMailQueueFactory(MailQueueFactory queueFactory)

Methods inherited from class java.lang.Object

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

Constructor Detail

JamesMailSpooler

public JamesMailSpooler()

Method Detail

setMailQueueFactory

public void setMailQueueFactory(MailQueueFactory queueFactory)

setMailProcessor

public void setMailProcessor(MailProcessor mailProcessor)

configure

public void configure(org.apache.commons.configuration.HierarchicalConfiguration config)
               throws org.apache.commons.configuration.ConfigurationException

Description copied from interface: Configurable

Configure the object. Be aware that no services are injected when this is called. If you need to access injected stuff do it in a method annotated with @PostConstruct

Specified by:

configure in interface Configurable

Throws:

org.apache.commons.configuration.ConfigurationException

See Also:

Configurable.configure(org.apache.commons.configuration.HierarchicalConfiguration)

init

@PostConstruct
public void init()
          throws Exception

Initializes the spool manager.

Throws:

Exception

run

public void run()

This routinely checks the message spool for messages, and processes them as necessary

Specified by:

run in interface Runnable

dispose

@PreDestroy
public void dispose()

The dispose operation is called at the end of a components lifecycle. Instances of this class use this method to release and destroy any resources that they own. This implementation shuts down the LinearProcessors managed by this JamesSpoolManager

See Also:

Disposable.dispose()

setLog

public void setLog(org.slf4j.Logger log)

Description copied from interface: LogEnabled

Sets the service log.

Specified by:

setLog in interface LogEnabled

Parameters:

log - not null

See Also:

LogEnabled.setLog(org.slf4j.Logger)

getThreadCount

public int getThreadCount()

Description copied from interface: MailSpoolerMBean

Return the number of threads used for spooling

Specified by:

getThreadCount in interface MailSpoolerMBean

Returns:

threadCount

See Also:

MailSpoolerMBean.getThreadCount()

getCurrentSpoolCount

public int getCurrentSpoolCount()

Specified by:

getCurrentSpoolCount in interface MailSpoolerMBean

Returns:

current spool count

See Also:

MailSpoolerMBean.getCurrentSpoolCount()