org.springframework.integration.handler

Class AbstractMessageHandler

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.AbstractMessageHandler

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.core.Ordered, ExpressionCapable, Orderable, NamedComponent, ConfigurableMetricsAware<AbstractMessageHandlerMetrics>, IntegrationManagement, IntegrationStatsManagement, MessageHandlerMetrics, TrackableComponent, org.springframework.messaging.MessageHandler

Direct Known Subclasses:

AbstractInternetProtocolSendingMessageHandler, AbstractMessageProducingHandler, AbstractMessageRouter, AbstractMqttMessageHandler, AbstractXmppConnectionAwareMessageHandler, ApplicationEventPublishingMessageHandler, ByteStreamWritingMessageHandler, CacheWritingMessageHandler, CharacterStreamWritingMessageHandler, CorrelatingMessageBarrier, DirectMessageSendingMessageHandler, ExpressionEvaluatingMessageHandler, FileTransferringMessageHandler, JdbcMessageHandler, JmsSendingMessageHandler, LoggingHandler, MailSendingMessageHandler, MethodInvokingMessageHandler, MongoDbStoringMessageHandler, NotificationPublishingMessageHandler, RedisPublishingMessageHandler, RedisQueueOutboundChannelAdapter, RedisStoreWritingMessageHandler, StatusUpdatingMessageHandler, StompMessageHandler, StoredProcMessageHandler, TcpSendingMessageHandler, WebSocketOutboundMessageHandler

@IntegrationManagedResource
public abstract class AbstractMessageHandler
extends IntegrationObjectSupport
implements org.springframework.messaging.MessageHandler, MessageHandlerMetrics, ConfigurableMetricsAware<AbstractMessageHandlerMetrics>, TrackableComponent, Orderable

Base class for MessageHandler implementations that provides basic validation and error handling capabilities. Asserts that the incoming Message is not null and that it does not contain a null payload. Converts checked exceptions into runtime MessagingExceptions.

Author:

Mark Fisher, Oleg Zhurakousky, Gary Russell

Field Summary

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
AbstractMessageHandler()

Method Summary

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(org.springframework.messaging.Message<?> message)
protected abstract void	handleMessageInternal(org.springframework.messaging.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)

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getComponentName

Constructor Detail

AbstractMessageHandler

public AbstractMessageHandler()

Method Detail

isLoggingEnabled

public boolean isLoggingEnabled()

Specified by:

isLoggingEnabled in interface IntegrationManagement

setLoggingEnabled

public void setLoggingEnabled(boolean loggingEnabled)

Specified by:

setLoggingEnabled in interface IntegrationManagement

setOrder

public void setOrder(int order)

Description copied from interface: Orderable

Set the order for this component.

Specified by:

setOrder in interface Orderable

Parameters:

order - the order.

getOrder

public int getOrder()

Specified by:

getOrder in interface org.springframework.core.Ordered

getComponentType

public String getComponentType()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this method to provide component type information.

Specified by:

getComponentType in interface NamedComponent

Overrides:

getComponentType in class IntegrationObjectSupport

setShouldTrack

public void setShouldTrack(boolean shouldTrack)

Specified by:

setShouldTrack in interface TrackableComponent

configureMetrics

public void configureMetrics(AbstractMessageHandlerMetrics metrics)

Specified by:

configureMetrics in interface ConfigurableMetricsAware<AbstractMessageHandlerMetrics>

onInit

protected void onInit()
               throws Exception

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class IntegrationObjectSupport

Throws:

Exception - Any exception.

handleMessage

public void handleMessage(org.springframework.messaging.Message<?> message)

Specified by:

handleMessage in interface org.springframework.messaging.MessageHandler

handleMessageInternal

protected abstract void handleMessageInternal(org.springframework.messaging.Message<?> message)
                                       throws Exception

Throws:

Exception

reset

public void reset()

Specified by:

reset in interface IntegrationManagement

getHandleCountLong

public long getHandleCountLong()

Specified by:

getHandleCountLong in interface MessageHandlerMetrics

Returns:

the number of successful handler calls

getHandleCount

public int getHandleCount()

Specified by:

getHandleCount in interface MessageHandlerMetrics

Returns:

the number of successful handler calls

getErrorCount

public int getErrorCount()

Specified by:

getErrorCount in interface MessageHandlerMetrics

Returns:

the number of failed handler calls

getErrorCountLong

public long getErrorCountLong()

Specified by:

getErrorCountLong in interface MessageHandlerMetrics

Returns:

the number of failed handler calls

getMeanDuration

public double getMeanDuration()

Specified by:

getMeanDuration in interface MessageHandlerMetrics

Returns:

the mean handler duration (milliseconds)

getMinDuration

public double getMinDuration()

Specified by:

getMinDuration in interface MessageHandlerMetrics

Returns:

the minimum handler duration (milliseconds)

getMaxDuration

public double getMaxDuration()

Specified by:

getMaxDuration in interface MessageHandlerMetrics

Returns:

the maximum handler duration (milliseconds)

getStandardDeviationDuration

public double getStandardDeviationDuration()

Specified by:

getStandardDeviationDuration in interface MessageHandlerMetrics

Returns:

the standard deviation handler duration (milliseconds)

getActiveCount

public int getActiveCount()

Specified by:

getActiveCount in interface MessageHandlerMetrics

getActiveCountLong

public long getActiveCountLong()

Specified by:

getActiveCountLong in interface MessageHandlerMetrics

getDuration

public Statistics getDuration()

Specified by:

getDuration in interface MessageHandlerMetrics

Returns:

summary statistics about the handler duration (milliseconds)

setStatsEnabled

public void setStatsEnabled(boolean statsEnabled)

Specified by:

setStatsEnabled in interface IntegrationStatsManagement

isStatsEnabled

public boolean isStatsEnabled()

Specified by:

isStatsEnabled in interface IntegrationStatsManagement

setCountsEnabled

public void setCountsEnabled(boolean countsEnabled)

Specified by:

setCountsEnabled in interface IntegrationManagement

isCountsEnabled

public boolean isCountsEnabled()

Specified by:

isCountsEnabled in interface IntegrationManagement

setManagedName

public void setManagedName(String managedName)

Specified by:

setManagedName in interface MessageHandlerMetrics

getManagedName

public String getManagedName()

Specified by:

getManagedName in interface MessageHandlerMetrics

setManagedType

public void setManagedType(String managedType)

Specified by:

setManagedType in interface MessageHandlerMetrics

getManagedType

public String getManagedType()

Specified by:

getManagedType in interface MessageHandlerMetrics