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 BeanFactoryAware
protected BeanFactory getBeanFactory()
protected MessageBuilderFactory getMessageBuilderFactory()
public String getComponentName()
getComponentName
in interface NamedComponent
public String getComponentType()
getComponentType
in interface NamedComponent
public void setBeanName(String name)
setBeanName
in interface BeanNameAware
public Message<Object> receive()
MessageSource
null
if no message is available.receive
in interface MessageSource<Object>