public class LifecycleMessageSourceManagement extends LifecycleMessageSourceMetrics implements MessageSourceManagement
LifecycleMessageSourceMetrics for sources that implement MessageSourceManagement.delegate| Constructor and Description |
|---|
LifecycleMessageSourceManagement(Lifecycle lifecycle,
MessageSourceManagement delegate) |
| Modifier and Type | Method and Description |
|---|---|
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.
|
getDelegate, getManagedName, getManagedType, getMessageCount, getMessageCountLong, isCountsEnabled, isLoggingEnabled, isRunning, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, start, stopclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetManagedName, getManagedType, getMessageCount, getMessageCountLong, setManagedName, setManagedTypeisCountsEnabled, isLoggingEnabled, reset, setCountsEnabled, setLoggingEnabledpublic LifecycleMessageSourceManagement(Lifecycle lifecycle, MessageSourceManagement delegate)
public 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)