org.springframework.integration.channel

Class AbstractMessageChannel

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.channel.AbstractMessageChannel

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, ChannelInterceptorAware, ExpressionCapable, NamedComponent, BaseChannelMetrics, ConfigurableMetricsAware<AbstractMessageChannelMetrics>, IntegrationManagement, IntegrationStatsManagement, MessageChannelMetrics, TrackableComponent, MessageChannel, InterceptableChannel

Direct Known Subclasses:

AbstractAmqpChannel, AbstractJmsChannel, AbstractPollableChannel, AbstractSubscribableChannel, FluxMessageChannel, SubscribableRedisChannel

@IntegrationManagedResource
public abstract class AbstractMessageChannel
extends IntegrationObjectSupport
implements MessageChannel, TrackableComponent, ChannelInterceptorAware, MessageChannelMetrics, ConfigurableMetricsAware<AbstractMessageChannelMetrics>

Base class for MessageChannel implementations providing common properties such as the channel name. Also provides the common functionality for sending and receiving Messages including the invocation of any ChannelInterceptors.

Author:

Mark Fisher, Oleg Zhurakousky, Gary Russell, Artem Bilan

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	AbstractMessageChannel.ChannelInterceptorList A convenience wrapper class for the list of ChannelInterceptors.

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields

Modifier and Type	Field and Description
protected AbstractMessageChannel.ChannelInterceptorList	interceptors
protected Set<MeterFacade>	meters

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

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.messaging.MessageChannel

INDEFINITE_TIMEOUT

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Constructor Summary

Constructors

Constructor and Description
AbstractMessageChannel()

Method Summary

Modifier and Type	Method and Description
void	addInterceptor(ChannelInterceptor interceptor) Add a channel interceptor to the end of the list.
void	addInterceptor(int index, ChannelInterceptor interceptor) Add a channel interceptor to the specified index of the list.
void	configureMetrics(AbstractMessageChannelMetrics metrics)
void	destroy()
protected abstract boolean	doSend(Message<?> message, long timeout) Subclasses must implement this method.
String	getComponentType() Subclasses may implement this method to provide component type information.
Statistics	getErrorRate()
String	getFullChannelName() Returns the fully qualified channel name including the application context id, if available.
protected AbstractMessageChannel.ChannelInterceptorList	getIChannelInterceptorList() Exposes the interceptor list instance for subclasses.
List<ChannelInterceptor>	getInterceptors() Return a read-only list of the configured interceptors.
double	getMaxSendDuration()
double	getMeanErrorRate()
double	getMeanErrorRatio()
double	getMeanSendDuration()
double	getMeanSendRate()
protected AbstractMessageChannelMetrics	getMetrics()
protected MetricsCaptor	getMetricsCaptor()
double	getMinSendDuration()
IntegrationManagement.ManagementOverrides	getOverrides() Return the overrides.
int	getSendCount()
long	getSendCountLong()
Statistics	getSendDuration()
int	getSendErrorCount()
long	getSendErrorCountLong()
Statistics	getSendRate()
double	getStandardDeviationSendDuration()
double	getTimeSinceLastSend()
boolean	isCountsEnabled()
boolean	isLoggingEnabled()
boolean	isStatsEnabled()
protected void	onInit() Subclasses may implement this for initialization logic.
void	registerMetricsCaptor(MetricsCaptor metricsCaptorToRegister) Inject a MetricsCaptor
boolean	removeInterceptor(ChannelInterceptor interceptor)
ChannelInterceptor	removeInterceptor(int index)
void	reset()
boolean	send(Message<?> message) Send a message on this channel.
boolean	send(Message<?> messageArg, long timeout) Send a message on this channel.
void	setCountsEnabled(boolean countsEnabled)
void	setDatatypes(Class<?>... datatypes) Specify the Message payload datatype(s) supported by this channel.
void	setInterceptors(List<ChannelInterceptor> interceptors) Set the list of channel interceptors.
void	setLoggingEnabled(boolean loggingEnabled)
void	setMessageConverter(MessageConverter messageConverter) Specify the MessageConverter to use when trying to convert to one of this channel's supported datatypes (in order) for a Message whose payload does not already match.
void	setShouldTrack(boolean shouldTrack)
void	setStatsEnabled(boolean statsEnabled)

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

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, 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

getBeanName, getComponentName

Methods inherited from interface org.springframework.integration.channel.ChannelInterceptorAware

getChannelInterceptors

Methods inherited from interface org.springframework.integration.support.management.MessageChannelMetrics

sendCount, sendErrorCount

Field Detail

interceptors

protected final AbstractMessageChannel.ChannelInterceptorList interceptors

meters

protected final Set<MeterFacade> meters

Constructor Detail

AbstractMessageChannel

public AbstractMessageChannel()

Method Detail

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

registerMetricsCaptor

public void registerMetricsCaptor(MetricsCaptor metricsCaptorToRegister)

Description copied from interface: IntegrationManagement

Inject a MetricsCaptor

Specified by:

registerMetricsCaptor in interface IntegrationManagement

Parameters:

metricsCaptorToRegister - the captor.

getMetricsCaptor

@Nullable
protected MetricsCaptor getMetricsCaptor()

setCountsEnabled

public void setCountsEnabled(boolean countsEnabled)

Specified by:

setCountsEnabled in interface IntegrationManagement

isCountsEnabled

public boolean isCountsEnabled()

Specified by:

isCountsEnabled in interface IntegrationManagement

setStatsEnabled

public void setStatsEnabled(boolean statsEnabled)

Specified by:

setStatsEnabled in interface IntegrationStatsManagement

isStatsEnabled

public boolean isStatsEnabled()

Specified by:

isStatsEnabled in interface IntegrationStatsManagement

isLoggingEnabled

public boolean isLoggingEnabled()

Specified by:

isLoggingEnabled in interface IntegrationManagement

setLoggingEnabled

public void setLoggingEnabled(boolean loggingEnabled)

Specified by:

setLoggingEnabled in interface IntegrationManagement

getMetrics

protected AbstractMessageChannelMetrics getMetrics()

configureMetrics

public void configureMetrics(AbstractMessageChannelMetrics metrics)

Specified by:

configureMetrics in interface ConfigurableMetricsAware<AbstractMessageChannelMetrics>

setDatatypes

public void setDatatypes(Class<?>... datatypes)

Specify the Message payload datatype(s) supported by this channel. If a payload type does not match directly, but the 'conversionService' is available, then type conversion will be attempted in the order of the elements provided in this array.

If this property is not set explicitly, any Message payload type will be accepted.

Parameters:

datatypes - The supported data types.

See Also:

setMessageConverter(MessageConverter)

setInterceptors

public void setInterceptors(List<ChannelInterceptor> interceptors)

Set the list of channel interceptors. This will clear any existing interceptors.

Specified by:

setInterceptors in interface InterceptableChannel

Parameters:

interceptors - The list of interceptors.

addInterceptor

public void addInterceptor(ChannelInterceptor interceptor)

Add a channel interceptor to the end of the list.

Specified by:

addInterceptor in interface InterceptableChannel

Parameters:

interceptor - The interceptor.

addInterceptor

public void addInterceptor(int index,
                           ChannelInterceptor interceptor)

Add a channel interceptor to the specified index of the list.

Specified by:

addInterceptor in interface InterceptableChannel

Parameters:

index - The index to add interceptor.

interceptor - The interceptor.

setMessageConverter

public void setMessageConverter(MessageConverter messageConverter)

Specify the MessageConverter to use when trying to convert to one of this channel's supported datatypes (in order) for a Message whose payload does not already match.

Note: only the MessageConverter.fromMessage(Message, Class) method is used. If the returned object is not a Message, the inbound headers will be copied; if the returned object is a Message, it is expected that the converter will have fully populated the headers; no further action is performed by the channel. If null is returned, conversion to the next datatype (if any) will be attempted. Defaults to a DefaultDatatypeChannelMessageConverter.

Parameters:

messageConverter - The message converter.

getInterceptors

public List<ChannelInterceptor> getInterceptors()

Return a read-only list of the configured interceptors.

Specified by:

getInterceptors in interface InterceptableChannel

removeInterceptor

public boolean removeInterceptor(ChannelInterceptor interceptor)

Specified by:

removeInterceptor in interface InterceptableChannel

removeInterceptor

@Nullable
public ChannelInterceptor removeInterceptor(int index)

Specified by:

removeInterceptor in interface InterceptableChannel

getIChannelInterceptorList

protected AbstractMessageChannel.ChannelInterceptorList getIChannelInterceptorList()

Exposes the interceptor list instance for subclasses.

Returns:

The channel interceptor list.

reset

public void reset()

Specified by:

reset in interface IntegrationManagement

getSendCount

public int getSendCount()

Specified by:

getSendCount in interface MessageChannelMetrics

Returns:

the number of successful sends

getSendCountLong

public long getSendCountLong()

Specified by:

getSendCountLong in interface MessageChannelMetrics

Returns:

the number of successful sends

getSendErrorCount

public int getSendErrorCount()

Specified by:

getSendErrorCount in interface MessageChannelMetrics

Returns:

the number of failed sends (either throwing an exception or rejected by the channel)

getSendErrorCountLong

public long getSendErrorCountLong()

Specified by:

getSendErrorCountLong in interface MessageChannelMetrics

Returns:

the number of failed sends (either throwing an exception or rejected by the channel)

getTimeSinceLastSend

public double getTimeSinceLastSend()

Specified by:

getTimeSinceLastSend in interface MessageChannelMetrics

Returns:

the time in milliseconds since the last send

getMeanSendRate

public double getMeanSendRate()

Specified by:

getMeanSendRate in interface MessageChannelMetrics

Returns:

the mean send rate (per second)

getMeanErrorRate

public double getMeanErrorRate()

Specified by:

getMeanErrorRate in interface MessageChannelMetrics

Returns:

the mean error rate (per second). Errors comprise all failed sends.

getMeanErrorRatio

public double getMeanErrorRatio()

Specified by:

getMeanErrorRatio in interface MessageChannelMetrics

Returns:

the mean ratio of failed to successful sends in approximately the last minute

getMeanSendDuration

public double getMeanSendDuration()

Specified by:

getMeanSendDuration in interface MessageChannelMetrics

Returns:

the mean send duration (milliseconds)

getMinSendDuration

public double getMinSendDuration()

Specified by:

getMinSendDuration in interface MessageChannelMetrics

Returns:

the minimum send duration (milliseconds) since startup

getMaxSendDuration

public double getMaxSendDuration()

Specified by:

getMaxSendDuration in interface MessageChannelMetrics

Returns:

the maximum send duration (milliseconds) since startup

getStandardDeviationSendDuration

public double getStandardDeviationSendDuration()

Specified by:

getStandardDeviationSendDuration in interface MessageChannelMetrics

Returns:

the standard deviation send duration (milliseconds)

getSendDuration

public Statistics getSendDuration()

Specified by:

getSendDuration in interface MessageChannelMetrics

Returns:

summary statistics about the send duration (milliseconds)

getSendRate

public Statistics getSendRate()

Specified by:

getSendRate in interface MessageChannelMetrics

Returns:

summary statistics about the send rates (per second)

getErrorRate

public Statistics getErrorRate()

Specified by:

getErrorRate in interface MessageChannelMetrics

Returns:

summary statistics about the error rates (per second)

getOverrides

public IntegrationManagement.ManagementOverrides getOverrides()

Description copied from interface: IntegrationManagement

Return the overrides.

Specified by:

getOverrides in interface IntegrationManagement

Returns:

the overrides.

onInit

protected void onInit()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class IntegrationObjectSupport

getFullChannelName

public String getFullChannelName()

Returns the fully qualified channel name including the application context id, if available.

Returns:

The name.

send

public boolean send(Message<?> message)

Send a message on this channel. If the channel is at capacity, this method will block until either space becomes available or the sending thread is interrupted.

Specified by:

send in interface MessageChannel

Parameters:

message - the Message to send

Returns:

true if the message is sent successfully or false if the sending thread is interrupted.

send

public boolean send(Message<?> messageArg,
                    long timeout)

Send a message on this channel. If the channel is at capacity, this method will block until either the timeout occurs or the sending thread is interrupted. If the specified timeout is 0, the method will return immediately. If less than zero, it will block indefinitely (see send(Message)).

Specified by:

send in interface MessageChannel

Parameters:

messageArg - the Message to send

timeout - the timeout in milliseconds

Returns:

true if the message is sent successfully, false if the message cannot be sent within the allotted time or the sending thread is interrupted.

doSend

protected abstract boolean doSend(Message<?> message,
                                  long timeout)

Subclasses must implement this method. A non-negative timeout indicates how long to wait if the channel is at capacity (if the value is 0, it must return immediately with or without success). A negative timeout value indicates that the method should block until either the message is accepted or the blocking thread is interrupted.

Parameters:

message - The message.

timeout - The timeout.

Returns:

true if the send was successful.

destroy

public void destroy()

Specified by:

destroy in interface DisposableBean

Specified by:

destroy in interface IntegrationManagement