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(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.
|
destroy, 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, messageCount, setManagedName, setManagedType
destroy, getOverrides, isCountsEnabled, isLoggingEnabled, registerMetricsCaptor, reset, setCountsEnabled, setLoggingEnabled
public LifecycleMessageSourceManagement(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)