org.apache.james.mailetcontainer.impl.camel

Class CamelMailetProcessor

java.lang.Object

org.apache.james.mailetcontainer.lib.AbstractStateMailetProcessor

org.apache.james.mailetcontainer.impl.camel.CamelMailetProcessor

All Implemented Interfaces:

org.apache.camel.CamelContextAware, Configurable, LogEnabled, MailProcessor

public class CamelMailetProcessor
extends AbstractStateMailetProcessor
implements org.apache.camel.CamelContextAware

AbstractStateMailetProcessor implementation which use Camel DSL for the Matcher / Mailet routing

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.james.mailetcontainer.lib.AbstractStateMailetProcessor

AbstractStateMailetProcessor.MailetProcessorListener, AbstractStateMailetProcessor.TerminatingMailet

Constructor Summary

Constructors

Constructor and Description
CamelMailetProcessor()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.camel.CamelContext	getCamelContext()
protected String	getEndpoint() Return the endpoint for the processorname.
void	init() Init the container
void	service(org.apache.mailet.Mail mail) Called by the mailet container to allow the mailet to process to a message.
void	setCamelContext(org.apache.camel.CamelContext context)
protected void	setupRouting(List<MatcherMailetPair> pairs) Setup the routing for the configured MatcherMailetPair's for this CamelProcessor

Methods inherited from class org.apache.james.mailetcontainer.lib.AbstractStateMailetProcessor

addListener, configure, destroy, getListeners, getLogger, getMailets, getMatchers, getState, removeListener, setLog, setMailetContext, setMailetLoader, setMatcherLoader, toProcessor

Methods inherited from class java.lang.Object

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

Constructor Detail

CamelMailetProcessor

public CamelMailetProcessor()

Method Detail

service

public void service(org.apache.mailet.Mail mail)
             throws javax.mail.MessagingException

Description copied from interface: MailProcessor

Called by the mailet container to allow the mailet to process to a message.

This method is only called after the mailet's init() method has completed successfully.

Mailets typically run inside multithreaded mailet containers that can handle multiple requests concurrently. Developers must be aware to synchronize access to any shared resources such as files, network connections, as well as the mailet's class and instance variables. More information on multithreaded programming in Java is available in the Java tutorial on multi-threaded programming.

Specified by:

service in interface MailProcessor

Parameters:

mail - - the Mail object that contains the message and routing information

Throws:

javax.mail.MessagingException - - if a message or address parsing exception occurs or an exception that interferes with the mailet's normal operation

See Also:

MailProcessor.service(org.apache.mailet.Mail)

getCamelContext

public org.apache.camel.CamelContext getCamelContext()

Specified by:

getCamelContext in interface org.apache.camel.CamelContextAware

See Also:

CamelContextAware.getCamelContext()

setCamelContext

public void setCamelContext(org.apache.camel.CamelContext context)

Specified by:

setCamelContext in interface org.apache.camel.CamelContextAware

See Also:

CamelContextAware.setCamelContext(org.apache.camel.CamelContext)

getEndpoint

protected String getEndpoint()

Return the endpoint for the processorname. This will return a "direct" endpoint.

Returns:

endPoint

init

@PostConstruct
public void init()
          throws Exception

Description copied from class: AbstractStateMailetProcessor

Init the container

Overrides:

init in class AbstractStateMailetProcessor

Throws:

Exception

setupRouting

protected void setupRouting(List<MatcherMailetPair> pairs)
                     throws javax.mail.MessagingException

Description copied from class: AbstractStateMailetProcessor

Setup the routing for the configured MatcherMailetPair's for this CamelProcessor

Specified by:

setupRouting in class AbstractStateMailetProcessor

Throws:

javax.mail.MessagingException

See Also:

(java.util.List)