org.apache.camel.component.mail
Class MailConsumer

java.lang.Object
  extended by org.apache.camel.impl.ServiceSupport
      extended by org.apache.camel.impl.DefaultConsumer<E>
          extended by org.apache.camel.impl.ScheduledPollConsumer<MailExchange>
              extended by org.apache.camel.component.mail.MailConsumer
All Implemented Interfaces:
Runnable, EventListener, MessageCountListener, org.apache.camel.Consumer<MailExchange>, org.apache.camel.Service

public class MailConsumer
extends org.apache.camel.impl.ScheduledPollConsumer<MailExchange>
implements MessageCountListener

A Consumer which consumes messages from JavaMail using a Transport and dispatches them to the Processor

Version:
$Revision: 523430 $

Constructor Summary
MailConsumer(MailEndpoint endpoint, org.apache.camel.Processor processor, Folder folder)
           
 
Method Summary
protected  void doStart()
           
protected  void doStop()
           
protected  void ensureFolderIsOpen()
           
protected  void flagMessageDeleted(Message message)
           
 void messagesAdded(MessageCountEvent event)
           
 void messagesRemoved(MessageCountEvent event)
           
protected  void poll()
           
protected  void processMessage(Message message)
           
 
Methods inherited from class org.apache.camel.impl.ScheduledPollConsumer
getDelay, getInitialDelay, getTimeUnit, isUseFixedDelay, run, setDelay, setInitialDelay, setTimeUnit, setUseFixedDelay
 
Methods inherited from class org.apache.camel.impl.DefaultConsumer
getEndpoint, getExceptionHandler, getProcessor, handleException, setExceptionHandler, toString
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, getThreadName, isStarted, isStopped, isStopping, nextThreadCounter, removeChildService, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

MailConsumer

public MailConsumer(MailEndpoint endpoint,
                    org.apache.camel.Processor processor,
                    Folder folder)
Method Detail

doStart

protected void doStart()
                throws Exception
Overrides:
doStart in class org.apache.camel.impl.ScheduledPollConsumer<MailExchange>
Throws:
Exception

doStop

protected void doStop()
               throws Exception
Overrides:
doStop in class org.apache.camel.impl.ScheduledPollConsumer<MailExchange>
Throws:
Exception

messagesAdded

public void messagesAdded(MessageCountEvent event)
Specified by:
messagesAdded in interface MessageCountListener

messagesRemoved

public void messagesRemoved(MessageCountEvent event)
Specified by:
messagesRemoved in interface MessageCountListener

poll

protected void poll()
             throws Exception
Specified by:
poll in class org.apache.camel.impl.ScheduledPollConsumer<MailExchange>
Throws:
Exception

processMessage

protected void processMessage(Message message)

ensureFolderIsOpen

protected void ensureFolderIsOpen()
                           throws MessagingException
Throws:
MessagingException

flagMessageDeleted

protected void flagMessageDeleted(Message message)
                           throws MessagingException
Throws:
MessagingException


Copyright © 2007 Apache Software Foundation. All Rights Reserved.