public class MailReceivingMessageSource extends AbstractMessageSource<java.lang.Object>
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.IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
Constructor and Description |
---|
MailReceivingMessageSource(MailReceiver mailReceiver) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.Object |
doReceive()
Subclasses must implement this method.
|
protected org.springframework.beans.factory.BeanFactory |
getBeanFactory() |
java.lang.String |
getComponentName() |
java.lang.String |
getComponentType() |
protected MessageBuilderFactory |
getMessageBuilderFactory() |
void |
setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
Specify a BeanFactory in order to enable resolution via
@beanName in the expression. |
void |
setBeanName(java.lang.String name) |
buildMessage, getManagedName, getManagedType, getMessageCount, getMessageCountLong, getOverrides, isCountsEnabled, isLoggingEnabled, receive, registerMetricsCaptor, reset, setCountsEnabled, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getEvaluationContext, getEvaluationContext, onInit, setConversionService
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setCounter
public MailReceivingMessageSource(MailReceiver mailReceiver)
public final void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
AbstractExpressionEvaluator
@beanName
in the expression.setBeanFactory
in interface org.springframework.beans.factory.BeanFactoryAware
setBeanFactory
in class AbstractExpressionEvaluator
protected org.springframework.beans.factory.BeanFactory getBeanFactory()
getBeanFactory
in class AbstractExpressionEvaluator
protected MessageBuilderFactory getMessageBuilderFactory()
getMessageBuilderFactory
in class AbstractExpressionEvaluator
public java.lang.String getComponentName()
getComponentName
in interface NamedComponent
getComponentName
in class AbstractMessageSource<java.lang.Object>
public java.lang.String getComponentType()
public void setBeanName(java.lang.String name)
setBeanName
in interface org.springframework.beans.factory.BeanNameAware
setBeanName
in class AbstractMessageSource<java.lang.Object>
protected java.lang.Object doReceive()
AbstractMessageSource
payload
of
type T, but the returned value may also be a Message
instance whose payload is of type T;
also can be AbstractIntegrationMessageBuilder
which is used for additional headers population.doReceive
in class AbstractMessageSource<java.lang.Object>