public class MailReceivingMessageSource extends Object implements MessageSource<Object>, BeanFactoryAware, BeanNameAware, NamedComponent
MessageSource implementation that delegates to a
MailReceiver to poll a mailbox. Each poll of the mailbox may
return more than one message which will then be stored in a queue.| Constructor and Description |
|---|
MailReceivingMessageSource(MailReceiver mailReceiver) |
| Modifier and Type | Method and Description |
|---|---|
protected BeanFactory |
getBeanFactory() |
String |
getComponentName() |
String |
getComponentType() |
protected MessageBuilderFactory |
getMessageBuilderFactory() |
Message<Object> |
receive()
Retrieve the next available message from this source.
|
void |
setBeanFactory(BeanFactory beanFactory) |
void |
setBeanName(String name) |
public MailReceivingMessageSource(MailReceiver mailReceiver)
public final void setBeanFactory(BeanFactory beanFactory)
setBeanFactory in interface BeanFactoryAwareprotected BeanFactory getBeanFactory()
protected MessageBuilderFactory getMessageBuilderFactory()
public String getComponentName()
getComponentName in interface NamedComponentpublic String getComponentType()
getComponentType in interface NamedComponentpublic void setBeanName(String name)
setBeanName in interface BeanNameAwarepublic Message<Object> receive()
MessageSourcenull if no message is available.receive in interface MessageSource<Object>