@IntegrationManagedResource public abstract class MessageHandlerSupport extends IntegrationObjectSupport implements MessageHandlerMetrics, ConfigurableMetricsAware<AbstractMessageHandlerMetrics>, TrackableComponent, Orderable, IntegrationPattern
MessagingExceptions.IntegrationManagement.ManagementOverridesEXPRESSION_PARSER, loggerMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAMEHIGHEST_PRECEDENCE, LOWEST_PRECEDENCE| Constructor and Description |
|---|
MessageHandlerSupport() |
| Modifier and Type | Method and Description |
|---|---|
protected TimerFacade |
buildSendTimer(boolean success,
String exception) |
void |
configureMetrics(AbstractMessageHandlerMetrics metrics) |
void |
destroy() |
int |
getActiveCount() |
long |
getActiveCountLong() |
String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
Statistics |
getDuration() |
int |
getErrorCount() |
long |
getErrorCountLong() |
int |
getHandleCount() |
long |
getHandleCountLong() |
protected AbstractMessageHandlerMetrics |
getHandlerMetrics() |
IntegrationPatternType |
getIntegrationPatternType()
Return a pattern type this component implements.
|
String |
getManagedName() |
String |
getManagedType() |
double |
getMaxDuration() |
double |
getMeanDuration() |
protected MetricsCaptor |
getMetricsCaptor() |
double |
getMinDuration() |
int |
getOrder() |
IntegrationManagement.ManagementOverrides |
getOverrides()
Return the overrides.
|
double |
getStandardDeviationDuration() |
boolean |
isCountsEnabled() |
boolean |
isLoggingEnabled() |
boolean |
isStatsEnabled() |
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
registerMetricsCaptor(MetricsCaptor metricsCaptorToRegister)
Inject a
MetricsCaptor |
void |
reset() |
protected TimerFacade |
sendTimer() |
void |
setCountsEnabled(boolean countsEnabled) |
void |
setLoggingEnabled(boolean loggingEnabled) |
void |
setManagedName(String managedName) |
void |
setManagedType(String managedType) |
void |
setOrder(int order)
Set the order for this component.
|
void |
setShouldTrack(boolean shouldTrack) |
void |
setStatsEnabled(boolean statsEnabled) |
protected boolean |
shouldTrack() |
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waiterrorCount, handleCountgetBeanName, getComponentNamepublic boolean isLoggingEnabled()
isLoggingEnabled in interface IntegrationManagementpublic void setLoggingEnabled(boolean loggingEnabled)
setLoggingEnabled in interface IntegrationManagementpublic void registerMetricsCaptor(MetricsCaptor metricsCaptorToRegister)
IntegrationManagementMetricsCaptorregisterMetricsCaptor in interface IntegrationManagementmetricsCaptorToRegister - the captor.protected AbstractMessageHandlerMetrics getHandlerMetrics()
protected MetricsCaptor getMetricsCaptor()
public void setOrder(int order)
Orderablepublic String getComponentType()
IntegrationObjectSupportgetComponentType in interface NamedComponentgetComponentType in class IntegrationObjectSupportpublic void setShouldTrack(boolean shouldTrack)
setShouldTrack in interface TrackableComponentprotected boolean shouldTrack()
public void configureMetrics(AbstractMessageHandlerMetrics metrics)
configureMetrics in interface ConfigurableMetricsAware<AbstractMessageHandlerMetrics>public IntegrationManagement.ManagementOverrides getOverrides()
IntegrationManagementgetOverrides in interface IntegrationManagementpublic IntegrationPatternType getIntegrationPatternType()
IntegrationPatterngetIntegrationPatternType in interface IntegrationPatternIntegrationPatternType this component implements.protected void onInit()
IntegrationObjectSupportonInit in class IntegrationObjectSupportprotected TimerFacade sendTimer()
protected TimerFacade buildSendTimer(boolean success, String exception)
public void reset()
reset in interface IntegrationManagementpublic long getHandleCountLong()
getHandleCountLong in interface MessageHandlerMetricspublic int getHandleCount()
getHandleCount in interface MessageHandlerMetricspublic int getErrorCount()
getErrorCount in interface MessageHandlerMetricspublic long getErrorCountLong()
getErrorCountLong in interface MessageHandlerMetricspublic double getMeanDuration()
getMeanDuration in interface MessageHandlerMetricspublic double getMinDuration()
getMinDuration in interface MessageHandlerMetricspublic double getMaxDuration()
getMaxDuration in interface MessageHandlerMetricspublic double getStandardDeviationDuration()
getStandardDeviationDuration in interface MessageHandlerMetricspublic int getActiveCount()
getActiveCount in interface MessageHandlerMetricspublic long getActiveCountLong()
getActiveCountLong in interface MessageHandlerMetricspublic Statistics getDuration()
getDuration in interface MessageHandlerMetricspublic void setStatsEnabled(boolean statsEnabled)
setStatsEnabled in interface IntegrationStatsManagementpublic boolean isStatsEnabled()
isStatsEnabled in interface IntegrationStatsManagementpublic void setCountsEnabled(boolean countsEnabled)
setCountsEnabled in interface IntegrationManagementpublic boolean isCountsEnabled()
isCountsEnabled in interface IntegrationManagementpublic void setManagedName(String managedName)
setManagedName in interface MessageHandlerMetricspublic String getManagedName()
getManagedName in interface MessageHandlerMetricspublic void setManagedType(String managedType)
setManagedType in interface MessageHandlerMetricspublic String getManagedType()
getManagedType in interface MessageHandlerMetricspublic void destroy()
destroy in interface DisposableBeandestroy in interface IntegrationManagement