public abstract class AbstractFetchLimitingMessageSource<T> extends AbstractMessageSource<T> implements MessageSourceManagement
IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER, logger
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, reset, setBeanName, setCountsEnabled, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionService
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getManagedName, getManagedType, getMessageCount, getMessageCountLong, setManagedName, setManagedType
getOverrides, isCountsEnabled, isLoggingEnabled, reset, setCountsEnabled, setLoggingEnabled
getComponentType
public void setMaxFetchSize(int maxFetchSize)
MessageSourceManagement
setMaxFetchSize
in interface MessageSourceManagement
maxFetchSize
- the max fetch size; a negative value means unlimited.public int getMaxFetchSize()
MessageSourceManagement
getMaxFetchSize
in interface MessageSourceManagement
MessageSourceManagement.setMaxFetchSize(int)
protected java.lang.Object doReceive()
AbstractMessageSource
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.