org.springframework.integration.redis.inbound

Class RedisStoreMessageSource

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.redis.inbound.RedisStoreMessageSource

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, InitializingBean, ApplicationContextAware, MessageSource<RedisStore>, NamedComponent

public class RedisStoreMessageSource
extends IntegrationObjectSupport
implements MessageSource<RedisStore>

Inbound channel adapter which returns a Message representing a view into a Redis store. The type of store depends on the collectionType attribute. Default is LIST. This adapter supports 5 types of collections identified by RedisCollectionFactoryBean.CollectionType

Since:

2.2

Author:

Oleg Zhurakousky, Gary Russell

Field Summary

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

logger

Constructor Summary

Constructors

Constructor and Description
RedisStoreMessageSource(RedisConnectionFactory connectionFactory, Expression keyExpression) Creates an instance with the provided RedisConnectionFactory and SpEL expression which should resolve to a 'key' name of the collection to be used.
RedisStoreMessageSource(RedisTemplate<String,?> redisTemplate, Expression keyExpression) Creates an instance with the provided RedisTemplate and SpEL expression which should resolve to a 'key' name of the collection to be used.

Method Summary

Methods

Modifier and Type	Method and Description
void	afterCommit(Object object)
void	afterRollback(Object object)
String	getComponentType() Subclasses may implement this method to provide component type information.
RedisStore	getResource()
protected void	onInit() Subclasses may implement this for initialization logic.
Message<RedisStore>	receive() Returns a Message with the view into a RedisStore identified by keyExpression
void	setCollectionType(RedisCollectionFactoryBean.CollectionType collectionType)

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

afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

RedisStoreMessageSource

public RedisStoreMessageSource(RedisTemplate<String,?> redisTemplate,
                       Expression keyExpression)

Creates an instance with the provided RedisTemplate and SpEL expression which should resolve to a 'key' name of the collection to be used. It assumes that RedisTemplate is fully initialized and ready to be used. The 'keyExpression' will be evaluated on every call to the receive() method.

Parameters:

redisTemplate - The Redis template.

keyExpression - The key expression.

RedisStoreMessageSource

public RedisStoreMessageSource(RedisConnectionFactory connectionFactory,
                       Expression keyExpression)

Creates an instance with the provided RedisConnectionFactory and SpEL expression which should resolve to a 'key' name of the collection to be used. It will create and initialize an instance of StringRedisTemplate that uses StringRedisSerializer for all serialization. The 'keyExpression' will be evaluated on every call to the receive() method.

Parameters:

connectionFactory - The connection factory.

keyExpression - The key expression.

Method Detail

setCollectionType

public void setCollectionType(RedisCollectionFactoryBean.CollectionType collectionType)

receive

public Message<RedisStore> receive()

Returns a Message with the view into a RedisStore identified by keyExpression

Specified by:

receive in interface MessageSource<RedisStore>

Returns:

The messasge or null.

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

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.

getResource

public RedisStore getResource()

afterCommit

public void afterCommit(Object object)

afterRollback

public void afterRollback(Object object)