public abstract class AbstractFetchLimitingMessageSource<T> extends AbstractMessageSource<T> implements MessageSourceManagement
IntegrationManagement.ManagementOverridesEXPRESSION_PARSER, loggerMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME| Constructor and Description |
|---|
AbstractFetchLimitingMessageSource() |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
doReceive()
Subclasses must implement this method.
|
protected abstract java.lang.Object |
doReceive(int maxFetchSize)
Subclasses must implement this method.
|
int |
getMaxFetchSize()
Return the max fetch size.
|
void |
setMaxFetchSize(int maxFetchSize)
Set the maximum number of objects the source should fetch if it is necessary to
fetch objects.
|
buildMessage, 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, waitgetManagedName, getManagedType, getMessageCount, getMessageCountLong, setCounter, setManagedName, setManagedTypegetOverrides, isCountsEnabled, isLoggingEnabled, registerMetricsCaptor, reset, setCountsEnabled, setLoggingEnabledgetComponentTypepublic void setMaxFetchSize(int maxFetchSize)
MessageSourceManagementsetMaxFetchSize in interface MessageSourceManagementmaxFetchSize - the max fetch size; a negative value means unlimited.public int getMaxFetchSize()
MessageSourceManagementgetMaxFetchSize in interface MessageSourceManagementMessageSourceManagement.setMaxFetchSize(int)protected java.lang.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<T>protected abstract java.lang.Object doReceive(int maxFetchSize)
maxFetchSize - the maximum number of messages to fetch if a fetch is
necessary.