com.consol.citrus.channel

Class MessageSelectingQueueChannel

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.channel.AbstractMessageChannel

org.springframework.integration.channel.AbstractPollableChannel

org.springframework.integration.channel.QueueChannel

com.consol.citrus.channel.MessageSelectingQueueChannel

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.integration.channel.ChannelInterceptorAware, org.springframework.integration.channel.QueueChannelOperations, org.springframework.integration.history.TrackableComponent, org.springframework.integration.support.context.NamedComponent, org.springframework.messaging.MessageChannel, org.springframework.messaging.PollableChannel

public class MessageSelectingQueueChannel
extends org.springframework.integration.channel.QueueChannel

Added selective consumption of messages according to a message selector implementation.

Author:

Christoph Deppisch

Nested Class Summary

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

org.springframework.integration.channel.AbstractMessageChannel.ChannelInterceptorList

Field Summary

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

queueSemaphore

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

logger

Fields inherited from interface org.springframework.messaging.MessageChannel

INDEFINITE_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
MessageSelectingQueueChannel() Default constructor.
MessageSelectingQueueChannel(BlockingQueue<org.springframework.messaging.Message<?>> queue) Create a channel with the specified queue.
MessageSelectingQueueChannel(int capacity) Create a channel with the specified queue capacity.

Method Summary

Modifier and Type	Method and Description
long	getPollingInterval() Gets the pollingInterval.
org.springframework.messaging.Message<?>	receive(org.springframework.integration.core.MessageSelector selector) Supports selective consumption of messages on the channel.
org.springframework.messaging.Message<?>	receive(org.springframework.integration.core.MessageSelector selector, long timeout) Consume messages on the channel via message selector.
void	setPollingInterval(long pollingInterval) Sets the pollingInterval.

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

clear, doReceive, doSend, getQueueSize, getRemainingCapacity, purge

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

receive, receive

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

addInterceptor, addInterceptor, getChannelInterceptors, getComponentType, getFullChannelName, getInterceptors, onInit, removeInterceptor, removeInterceptor, send, send, setConversionService, setDatatypes, setInterceptors, setMessageConverter, setShouldTrack

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

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setMessageBuilderFactory, 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.messaging.MessageChannel

send, send

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

getComponentName

Constructor Detail

MessageSelectingQueueChannel

public MessageSelectingQueueChannel(BlockingQueue<org.springframework.messaging.Message<?>> queue)

Create a channel with the specified queue.

MessageSelectingQueueChannel

public MessageSelectingQueueChannel(int capacity)

Create a channel with the specified queue capacity.

MessageSelectingQueueChannel

public MessageSelectingQueueChannel()

Default constructor.

Method Detail

receive

public org.springframework.messaging.Message<?> receive(org.springframework.integration.core.MessageSelector selector)

Supports selective consumption of messages on the channel. The first message to be accepted by given message selector is returned as result.

Parameters:

selector -

Returns:

receive

public org.springframework.messaging.Message<?> receive(org.springframework.integration.core.MessageSelector selector,
                                                        long timeout)

Consume messages on the channel via message selector. Timeout forces several retries with polling interval setting.

Parameters:

selector -

timeout -

Returns:

getPollingInterval

public long getPollingInterval()

Gets the pollingInterval.

Returns:

the pollingInterval the pollingInterval to get.

setPollingInterval

public void setPollingInterval(long pollingInterval)

Sets the pollingInterval.

Parameters:

pollingInterval - the pollingInterval to set