org.springframework.integration.redis.inbound

Class RedisQueueMessageDrivenEndpoint

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.endpoint.AbstractEndpoint

org.springframework.integration.endpoint.MessageProducerSupport

org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint

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.context.ApplicationEventPublisherAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, MessageProducer, TrackableComponent, NamedComponent

@ManagedResource
public class RedisQueueMessageDrivenEndpoint
extends MessageProducerSupport
implements org.springframework.context.ApplicationEventPublisherAware

Since:

3.0

Author:

Mark Fisher, Gunnar Hillert, Artem Bilan

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_RECEIVE_TIMEOUT
static long	DEFAULT_RECOVERY_INTERVAL

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

logger

Constructor Summary

Constructors

Constructor and Description
RedisQueueMessageDrivenEndpoint(java.lang.String queueName, org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)

Method Summary

Methods

Modifier and Type	Method and Description
void	clearQueue() Clear the Redis Queue specified by boundListOperations.
protected void	doStart() Takes no action by default.
protected void	doStop() Takes no action by default.
java.lang.String	getComponentType() Subclasses may implement this method to provide component type information.
long	getQueueSize() Returns the size of the Queue specified by boundListOperations.
boolean	isListening()
protected void	onInit() Subclasses may implement this for initialization logic.
void	setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)
void	setErrorChannel(MessageChannel errorChannel)
void	setExpectMessage(boolean expectMessage) When data is retrieved from the Redis queue, does the returned data represent just the payload for a Message, or does the data represent a serialized Message?.
void	setReceiveTimeout(long receiveTimeout) This timeout (milliseconds) is used when retrieving elements from the queue specified by boundListOperations.
void	setRecoveryInterval(long recoveryInterval)
void	setSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> serializer)
void	setTaskExecutor(java.util.concurrent.Executor taskExecutor)

Methods inherited from class org.springframework.integration.endpoint.MessageProducerSupport

sendMessage, setOutputChannel, setSendTimeout, setShouldTrack

Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint

getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop

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

afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, 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

Field Detail

DEFAULT_RECEIVE_TIMEOUT

public static final long DEFAULT_RECEIVE_TIMEOUT

See Also:

Constant Field Values

DEFAULT_RECOVERY_INTERVAL

public static final long DEFAULT_RECOVERY_INTERVAL

See Also:

Constant Field Values

Constructor Detail

RedisQueueMessageDrivenEndpoint

public RedisQueueMessageDrivenEndpoint(java.lang.String queueName,
                               org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)

Parameters:

queueName - Must not be an empty String

connectionFactory - Must not be null

Method Detail

setApplicationEventPublisher

public void setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)

Specified by:

setApplicationEventPublisher in interface org.springframework.context.ApplicationEventPublisherAware

setSerializer

public void setSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> serializer)

setExpectMessage

public void setExpectMessage(boolean expectMessage)

When data is retrieved from the Redis queue, does the returned data represent just the payload for a Message, or does the data represent a serialized Message?. expectMessage defaults to false. This means the retrieved data will be used as the payload for a new Spring Integration Message. Otherwise, the data is deserialized as Spring Integration Message.

Parameters:

expectMessage - Defaults to false

setReceiveTimeout

public void setReceiveTimeout(long receiveTimeout)

This timeout (milliseconds) is used when retrieving elements from the queue specified by boundListOperations.

If the queue does contain elements, the data is retrieved immediately. However, if the queue is empty, the Redis connection is blocked until either an element can be retrieved from the queue or until the specified timeout passes.

A timeout of zero can be used to block indefinitely. If not set explicitly the timeout value will default to 1000

See also: http://redis.io/commands/brpop

Parameters:

receiveTimeout - Must be non-negative. Specified in milliseconds.

setTaskExecutor

public void setTaskExecutor(java.util.concurrent.Executor taskExecutor)

setErrorChannel

public void setErrorChannel(MessageChannel errorChannel)

Overrides:

setErrorChannel in class MessageProducerSupport

setRecoveryInterval

public void setRecoveryInterval(long recoveryInterval)

onInit

protected void onInit()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class MessageProducerSupport

getComponentType

public java.lang.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

doStart

protected void doStart()

Description copied from class: MessageProducerSupport

Takes no action by default. Subclasses may override this if they need lifecycle-managed behavior.

Overrides:

doStart in class MessageProducerSupport

doStop

protected void doStop()

Description copied from class: MessageProducerSupport

Takes no action by default. Subclasses may override this if they need lifecycle-managed behavior.

Overrides:

doStop in class MessageProducerSupport

isListening

public boolean isListening()

getQueueSize

@ManagedMetric
public long getQueueSize()

Returns the size of the Queue specified by boundListOperations. The queue is represented by a Redis list. If the queue does not exist 0 is returned. See also http://redis.io/commands/llen

Returns:

Size of the queue. Never negative.

clearQueue

@ManagedOperation
public void clearQueue()

Clear the Redis Queue specified by boundListOperations.