Class RedisStoreMessageSource

java.lang.Object

org.springframework.integration.util.AbstractExpressionEvaluator

org.springframework.integration.endpoint.AbstractMessageSource<RedisStore>

org.springframework.integration.redis.inbound.RedisStoreMessageSource

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, MessageSource<RedisStore>, IntegrationPattern, NamedComponent, IntegrationInboundManagement, IntegrationManagement

public class RedisStoreMessageSource
extends AbstractMessageSource<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, Artem Bilan

Nested Class Summary

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

IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class org.springframework.integration.util.AbstractExpressionEvaluator

EXPRESSION_PARSER, logger

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

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Constructor Summary

Constructors

Constructor	Description
RedisStoreMessageSource(RedisConnectionFactory connectionFactory, Expression keyExpression)	Create 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)	Create an instance with the provided RedisTemplate and SpEL expression which should resolve to a 'key' name of the collection to be used.

Method Summary

Modifier and Type	Method	Description
protected RedisStore	doReceive()	Return a Message with the view into a RedisStore identified by keyExpression
String	getComponentType()
protected void	onInit()
void	setCollectionType(RedisCollectionFactoryBean.CollectionType collectionType)

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

buildMessage, destroy, getBeanName, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType

Methods inherited from class org.springframework.integration.util.AbstractExpressionEvaluator

afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionService, setSimpleEvaluationContext

Methods inherited from class java.lang.Object

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

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

getThisAs, isObserved, registerObservationRegistry

Methods inherited from interface org.springframework.integration.core.MessageSource

getIntegrationPatternType

Constructor Details

RedisStoreMessageSource

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

Create 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 AbstractMessageSource.receive() method.

Parameters:

redisTemplate - The Redis template.

keyExpression - The key expression.

RedisStoreMessageSource

public RedisStoreMessageSource(RedisConnectionFactory connectionFactory,
 Expression keyExpression)

Create 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 AbstractMessageSource.receive() method.

Parameters:

connectionFactory - The connection factory.

keyExpression - The key expression.

Method Details

setCollectionType

public void setCollectionType(RedisCollectionFactoryBean.CollectionType collectionType)

onInit

protected void onInit()

Overrides:

onInit in class AbstractExpressionEvaluator

doReceive

protected RedisStore doReceive()

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

Specified by:

doReceive in class AbstractMessageSource<RedisStore>

Returns:

The value returned.

getComponentType

public String getComponentType()