@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, wait
setCounter
registerMetricsCaptor
protected 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.Lifecycle
public java.lang.String getManagedName()
getManagedName
in interface MessageSourceMetrics
public java.lang.String getManagedType()
getManagedType
in interface MessageSourceMetrics
public int getMessageCount()
getMessageCount
in interface MessageSourceMetrics
public long getMessageCountLong()
getMessageCountLong
in interface MessageSourceMetrics
public void setCountsEnabled(boolean countsEnabled)
setCountsEnabled
in interface IntegrationManagement
public boolean isCountsEnabled()
isCountsEnabled
in interface IntegrationManagement
public void setLoggingEnabled(boolean enabled)
setLoggingEnabled
in interface IntegrationManagement
public boolean isLoggingEnabled()
isLoggingEnabled
in interface IntegrationManagement
public void setManagedName(java.lang.String name)
setManagedName
in interface MessageSourceMetrics
public void setManagedType(java.lang.String source)
setManagedType
in interface MessageSourceMetrics
public IntegrationManagement.ManagementOverrides getOverrides()
IntegrationManagement
getOverrides
in interface IntegrationManagement