public abstract class AbstractFetchLimitingMessageSource<T> extends AbstractMessageSource<T> implements MessageSourceManagement
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, isCountsEnabled, isLoggingEnabled, receive, reset, setBeanName, setCountsEnabled, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedTypeafterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionServiceclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetManagedName, getManagedType, getMessageCount, getMessageCountLong, setManagedName, setManagedTypeisCountsEnabled, isLoggingEnabled, 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()
AbstractMessageSourcedoReceive 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.