public class MailReceivingMessageSource extends AbstractMessageSource<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.ManagementOverridesEXPRESSION_PARSER, loggerMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME| Constructor and Description |
|---|
MailReceivingMessageSource(MailReceiver mailReceiver) |
| Modifier and Type | Method and Description |
|---|---|
protected Object |
doReceive()
Subclasses must implement this method.
|
String |
getComponentType() |
buildMessage, destroy, getBeanName, getComponentName, getManagedName, getManagedType, getMessageCount, getMessageCountLong, getOverrides, isCountsEnabled, isLoggingEnabled, receive, registerMetricsCaptor, reset, setBeanName, setCountsEnabled, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedTypeafterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, onInit, setBeanFactory, setConversionServiceclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitmessageCountpublic MailReceivingMessageSource(MailReceiver mailReceiver)
public String getComponentType()
protected Object doReceive()
AbstractMessageSourcepayload 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<Object>