public class MessageProcessorMessageSource extends AbstractMessageSource<Object>
MessageSource
strategy implementation
to produce a Message
from underlying
messageProcessor for polling endpoints.IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER, logger
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
Constructor and Description |
---|
MessageProcessorMessageSource(MessageProcessor<?> messageProcessor) |
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, setManagedType
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, onInit, setBeanFactory, setConversionService
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
messageCount
public MessageProcessorMessageSource(MessageProcessor<?> messageProcessor)
public String getComponentType()
protected 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<Object>