public class LifecycleMessageSourceManagement extends LifecycleMessageSourceMetrics implements MessageSourceManagement
LifecycleMessageSourceMetrics
for sources that implement MessageSourceManagement
.IntegrationManagement.ManagementOverrides
delegate
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
Constructor and Description |
---|
LifecycleMessageSourceManagement(org.springframework.context.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, getOverrides, isCountsEnabled, isLoggingEnabled, isRunning, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getManagedName, getManagedType, getMessageCount, getMessageCountLong, setCounter, setManagedName, setManagedType
getOverrides, isCountsEnabled, isLoggingEnabled, registerMetricsCaptor, reset, setCountsEnabled, setLoggingEnabled
public LifecycleMessageSourceManagement(org.springframework.context.Lifecycle lifecycle, MessageSourceManagement delegate)
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)