@IntegrationManagedResource public abstract class AbstractMessageHandler extends IntegrationObjectSupport implements MessageHandler, MessageHandlerMetrics, ConfigurableMetricsAware<AbstractMessageHandlerMetrics>, TrackableComponent, Orderable
MessagingExceptions.EXPRESSION_PARSER, loggerHIGHEST_PRECEDENCE, LOWEST_PRECEDENCE| Constructor and Description |
|---|
AbstractMessageHandler() |
| Modifier and Type | Method and Description |
|---|---|
void |
configureMetrics(AbstractMessageHandlerMetrics metrics) |
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() |
String |
getManagedName() |
String |
getManagedType() |
double |
getMaxDuration() |
double |
getMeanDuration() |
double |
getMinDuration() |
int |
getOrder() |
double |
getStandardDeviationDuration() |
void |
handleMessage(Message<?> message) |
protected abstract void |
handleMessageInternal(Message<?> message) |
boolean |
isCountsEnabled() |
boolean |
isLoggingEnabled() |
boolean |
isStatsEnabled() |
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
reset() |
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) |
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetComponentNamepublic boolean isLoggingEnabled()
isLoggingEnabled in interface IntegrationManagementpublic void setLoggingEnabled(boolean loggingEnabled)
setLoggingEnabled in interface IntegrationManagementpublic void setOrder(int order)
Orderablepublic String getComponentType()
IntegrationObjectSupportgetComponentType in interface NamedComponentgetComponentType in class IntegrationObjectSupportpublic void setShouldTrack(boolean shouldTrack)
setShouldTrack in interface TrackableComponentpublic void configureMetrics(AbstractMessageHandlerMetrics metrics)
configureMetrics in interface ConfigurableMetricsAware<AbstractMessageHandlerMetrics>protected void onInit()
throws Exception
IntegrationObjectSupportonInit in class IntegrationObjectSupportException - Any exception.public final void handleMessage(Message<?> message)
handleMessage in interface MessageHandlerprotected abstract void handleMessageInternal(Message<?> message) throws Exception
Exceptionpublic 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 MessageHandlerMetrics