org.springframework.integration.channel

Class QueueChannel

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.channel.AbstractMessageChannel

org.springframework.integration.channel.AbstractPollableChannel

org.springframework.integration.channel.QueueChannel

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, ChannelInterceptorAware, ExecutorChannelInterceptorAware, QueueChannelOperations, ExpressionCapable, NamedComponent, ConfigurableMetricsAware<AbstractMessageChannelMetrics>, IntegrationManagement, IntegrationStatsManagement, MessageChannelMetrics, PollableChannelManagement, QueueChannelManagement, TrackableComponent, org.springframework.messaging.MessageChannel, org.springframework.messaging.PollableChannel

Direct Known Subclasses:

PriorityChannel, RendezvousChannel

public class QueueChannel
extends AbstractPollableChannel
implements QueueChannelOperations, QueueChannelManagement

Simple implementation of a message channel. Each Message is placed in a BlockingQueue whose capacity may be specified upon construction. The capacity must be a positive integer value. For a zero-capacity version based upon a SynchronousQueue, consider the RendezvousChannel.

Author:

Mark Fisher, Oleg Zhurakousky, Gary Russell, Artem Bilan

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.integration.channel.AbstractMessageChannel

AbstractMessageChannel.ChannelInterceptorList

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

IntegrationManagement.ManagementOverrides

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.Semaphore	queueSemaphore

Fields inherited from class org.springframework.integration.channel.AbstractMessageChannel

interceptors, meters

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

EXPRESSION_PARSER, logger

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

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Fields inherited from interface org.springframework.messaging.MessageChannel

INDEFINITE_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
QueueChannel() Create a channel with "unbounded" queue capacity.
QueueChannel(int capacity) Create a channel with the specified queue capacity.
QueueChannel(java.util.Queue<org.springframework.messaging.Message<?>> queue) Create a channel with the specified queue.

Method Summary

Modifier and Type	Method and Description
java.util.List<org.springframework.messaging.Message<?>>	clear() Remove all Messages from this channel.
protected org.springframework.messaging.Message<?>	doReceive(long timeout) Subclasses must implement this method.
protected boolean	doSend(org.springframework.messaging.Message<?> message, long timeout) Subclasses must implement this method.
int	getQueueSize()
int	getRemainingCapacity()
java.util.List<org.springframework.messaging.Message<?>>	purge(MessageSelector selector) Remove any Messages that are not accepted by the provided selector.

Methods inherited from class org.springframework.integration.channel.AbstractPollableChannel

addInterceptor, addInterceptor, destroy, getReceiveCount, getReceiveCountLong, getReceiveErrorCount, getReceiveErrorCountLong, hasExecutorInterceptors, receive, receive, removeInterceptor, removeInterceptor, setInterceptors

Methods inherited from class org.springframework.integration.channel.AbstractMessageChannel

configureMetrics, getChannelInterceptors, getComponentType, getErrorRate, getFullChannelName, getInterceptors, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMetrics, getMetricsCaptor, getMinSendDuration, getOverrides, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onInit, registerMetricsCaptor, reset, send, send, setCountsEnabled, setDatatypes, setLoggingEnabled, setMessageConverter, setShouldTrack, setStatsEnabled

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

afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanFactory, 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.management.PollableChannelManagement

getReceiveCount, getReceiveCountLong, getReceiveErrorCount, getReceiveErrorCountLong

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

getErrorRate, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMinSendDuration, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend

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

isStatsEnabled, setStatsEnabled

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

getOverrides, isCountsEnabled, isLoggingEnabled, registerMetricsCaptor, reset, setCountsEnabled, setLoggingEnabled

Methods inherited from interface org.springframework.beans.factory.DisposableBean

destroy

Methods inherited from interface org.springframework.messaging.MessageChannel

send, send

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

getChannelInterceptors

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

getComponentName

Field Detail

queueSemaphore

protected final java.util.concurrent.Semaphore queueSemaphore

Constructor Detail

QueueChannel

public QueueChannel(java.util.Queue<org.springframework.messaging.Message<?>> queue)

Create a channel with the specified queue.

Parameters:

queue - The queue.

QueueChannel

public QueueChannel(int capacity)

Create a channel with the specified queue capacity.

Parameters:

capacity - The capacity.

QueueChannel

public QueueChannel()

Create a channel with "unbounded" queue capacity. The actual capacity value is Integer.MAX_VALUE. Note that a bounded queue is recommended, since an unbounded queue may lead to OutOfMemoryErrors.

Method Detail

doSend

protected boolean doSend(org.springframework.messaging.Message<?> message,
                         long timeout)

Description copied from class: AbstractMessageChannel

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.

Specified by:

doSend in class AbstractMessageChannel

Parameters:

message - The message.

timeout - The timeout.

Returns:

true if the send was successful.

doReceive

protected org.springframework.messaging.Message<?> doReceive(long timeout)

Description copied from class: AbstractPollableChannel

Subclasses must implement this method. A non-negative timeout indicates how long to wait if the channel is empty (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 a message is available or the blocking thread is interrupted.

Specified by:

doReceive in class AbstractPollableChannel

Parameters:

timeout - The timeout.

Returns:

The message, or null.

clear

public java.util.List<org.springframework.messaging.Message<?>> clear()

Description copied from interface: QueueChannelOperations

Remove all Messages from this channel.

Specified by:

clear in interface QueueChannelOperations

Returns:

The messages that were removed.

purge

public java.util.List<org.springframework.messaging.Message<?>> purge(MessageSelector selector)

Description copied from interface: QueueChannelOperations

Remove any Messages that are not accepted by the provided selector.

Specified by:

purge in interface QueueChannelOperations

Parameters:

selector - The message selector.

Returns:

The list of messages that were purged.

getQueueSize

public int getQueueSize()

Specified by:

getQueueSize in interface QueueChannelOperations

Specified by:

getQueueSize in interface QueueChannelManagement

Returns:

The current number of queued Messages in this channel.

getRemainingCapacity

public int getRemainingCapacity()

Specified by:

getRemainingCapacity in interface QueueChannelOperations

Specified by:

getRemainingCapacity in interface QueueChannelManagement

Returns:

The remaining capacity of this channel.