@IntegrationManagedResource public class LifecycleMessageSourceMetrics extends java.lang.Object implements MessageSourceMetrics, org.springframework.context.Lifecycle
MessageSourceMetrics that exposes in addition the Lifecycle interface.
The lifecycle methods can be used to start and stop polling endpoints, for instance, in a live system.IntegrationManagement.ManagementOverrides| Modifier and Type | Field and Description |
|---|---|
protected MessageSourceMetrics |
delegate |
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME| Constructor and Description |
|---|
LifecycleMessageSourceMetrics(org.springframework.context.Lifecycle lifecycle,
MessageSourceMetrics delegate) |
| Modifier and Type | Method and Description |
|---|---|
MessageSourceMetrics |
getDelegate() |
java.lang.String |
getManagedName() |
java.lang.String |
getManagedType() |
int |
getMessageCount() |
long |
getMessageCountLong() |
IntegrationManagement.ManagementOverrides |
getOverrides()
Return the overrides.
|
boolean |
isCountsEnabled() |
boolean |
isLoggingEnabled() |
boolean |
isRunning() |
void |
reset() |
void |
setCountsEnabled(boolean countsEnabled) |
void |
setLoggingEnabled(boolean enabled) |
void |
setManagedName(java.lang.String name) |
void |
setManagedType(java.lang.String source) |
void |
start() |
void |
stop() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitsetCounterregisterMetricsCaptorprotected final MessageSourceMetrics delegate
public LifecycleMessageSourceMetrics(org.springframework.context.Lifecycle lifecycle,
MessageSourceMetrics delegate)
public MessageSourceMetrics getDelegate()
@ManagedOperation public void reset()
reset in interface IntegrationManagement@ManagedAttribute public boolean isRunning()
isRunning in interface org.springframework.context.Lifecycle@ManagedOperation public void start()
start in interface org.springframework.context.Lifecycle@ManagedOperation public void stop()
stop in interface org.springframework.context.Lifecyclepublic java.lang.String getManagedName()
getManagedName in interface MessageSourceMetricspublic java.lang.String getManagedType()
getManagedType in interface MessageSourceMetricspublic int getMessageCount()
getMessageCount in interface MessageSourceMetricspublic long getMessageCountLong()
getMessageCountLong in interface MessageSourceMetricspublic void setCountsEnabled(boolean countsEnabled)
setCountsEnabled in interface IntegrationManagementpublic boolean isCountsEnabled()
isCountsEnabled in interface IntegrationManagementpublic void setLoggingEnabled(boolean enabled)
setLoggingEnabled in interface IntegrationManagementpublic boolean isLoggingEnabled()
isLoggingEnabled in interface IntegrationManagementpublic void setManagedName(java.lang.String name)
setManagedName in interface MessageSourceMetricspublic void setManagedType(java.lang.String source)
setManagedType in interface MessageSourceMetricspublic IntegrationManagement.ManagementOverrides getOverrides()
IntegrationManagementgetOverrides in interface IntegrationManagement