org.springframework.integration.support.management

Class LifecycleTrackableMessageSourceManagement

java.lang.Object

org.springframework.integration.support.management.LifecycleMessageSourceMetrics

org.springframework.integration.support.management.LifecycleTrackableMessageSourceMetrics

org.springframework.integration.support.management.LifecycleTrackableMessageSourceManagement

All Implemented Interfaces:

DisposableBean, Lifecycle, NamedComponent, BaseSourceMetrics, IntegrationManagement, MessageSourceManagement, MessageSourceMetrics, TrackableComponent

public class LifecycleTrackableMessageSourceManagement
extends LifecycleTrackableMessageSourceMetrics
implements MessageSourceManagement

An extension to LifecycleTrackableMessageSourceMetrics for sources that implement MessageSourceManagement.

Since:

5.0

Author:

Gary Russell

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class org.springframework.integration.support.management.LifecycleMessageSourceMetrics

delegate

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Constructor Summary

Constructors

Constructor and Description
LifecycleTrackableMessageSourceManagement(Lifecycle lifecycle, MessageSourceManagement delegate)

Method Summary

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.

Methods inherited from class org.springframework.integration.support.management.LifecycleTrackableMessageSourceMetrics

getBeanName, getComponentName, getComponentType, setShouldTrack

Methods inherited from class org.springframework.integration.support.management.LifecycleMessageSourceMetrics

destroy, getDelegate, getManagedName, getManagedType, getMessageCount, getMessageCountLong, getOverrides, isCountsEnabled, isLoggingEnabled, isRunning, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.integration.support.management.MessageSourceMetrics

getManagedName, getManagedType, getMessageCount, getMessageCountLong, messageCount, setManagedName, setManagedType

Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement

destroy, getOverrides, isCountsEnabled, isLoggingEnabled, registerMetricsCaptor, reset, setCountsEnabled, setLoggingEnabled

Constructor Detail

LifecycleTrackableMessageSourceManagement

public LifecycleTrackableMessageSourceManagement(Lifecycle lifecycle,
                                                 MessageSourceManagement delegate)

Method Detail

setMaxFetchSize

public void setMaxFetchSize(int maxFetchSize)

Description copied from interface: MessageSourceManagement

Set the maximum number of objects the source should fetch if it is necessary to fetch objects. Setting the maxFetchSize to 0 disables remote fetching, a negative value indicates no limit.

Specified by:

setMaxFetchSize in interface MessageSourceManagement

Parameters:

maxFetchSize - the max fetch size; a negative value means unlimited.

getMaxFetchSize

public int getMaxFetchSize()

Description copied from interface: MessageSourceManagement

Return the max fetch size.

Specified by:

getMaxFetchSize in interface MessageSourceManagement

Returns:

the max fetch size.

See Also:

MessageSourceManagement.setMaxFetchSize(int)