org.springframework.integration.redis.inbound
Class RedisStoreMessageSource
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.redis.inbound.RedisStoreMessageSource
- All Implemented Interfaces:
- org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, NamedComponent, MessageSource<org.springframework.data.redis.support.collections.RedisStore>
public class RedisStoreMessageSource
- extends IntegrationObjectSupport
- implements MessageSource<org.springframework.data.redis.support.collections.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
Constructor Summary |
RedisStoreMessageSource(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory,
org.springframework.expression.Expression keyExpression)
Creates this instance with provided RedisConnectionFactory and SpEL expression
which should resolve to a 'key' name of the collection to be used. |
RedisStoreMessageSource(org.springframework.data.redis.core.RedisTemplate<java.lang.String,?> redisTemplate,
org.springframework.expression.Expression keyExpression)
Creates this instance with provided RedisTemplate and SpEL expression
which should resolve to a 'key' name of the collection to be used. |
Method Summary |
void |
afterCommit(java.lang.Object object)
|
void |
afterRollback(java.lang.Object object)
|
org.springframework.data.redis.support.collections.RedisStore |
getResource()
|
protected void |
onInit()
Subclasses may implement this for initialization logic. |
Message<org.springframework.data.redis.support.collections.RedisStore> |
receive()
Returns a Message with the view into a RedisStore identified
by keyExpression |
void |
setCollectionType(org.springframework.data.redis.support.collections.RedisCollectionFactoryBean.CollectionType collectionType)
|
void |
setHashKeySerializer(org.springframework.data.redis.serializer.RedisSerializer<?> hashKeySerializer)
|
void |
setHashValueSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> hashValueSerializer)
|
void |
setKeySerializer(org.springframework.data.redis.serializer.RedisSerializer<?> keySerializer)
|
void |
setValueSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> valueSerializer)
|
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport |
afterPropertiesSet, getBeanFactory, getComponentName, getComponentType, getConversionService, getTaskScheduler, setBeanFactory, setBeanName, setComponentName, setConversionService, setTaskScheduler, toString |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
RedisStoreMessageSource
public RedisStoreMessageSource(org.springframework.data.redis.core.RedisTemplate<java.lang.String,?> redisTemplate,
org.springframework.expression.Expression keyExpression)
- Creates this instance with 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
- keyExpression
-
RedisStoreMessageSource
public RedisStoreMessageSource(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory,
org.springframework.expression.Expression keyExpression)
- Creates this instance with 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 the RedisTemplate
using
StringRedisSerializer
as key serializer and JdkSerializationRedisSerializer
for
value, hashKey and hashValue serializer.
The 'keyExpression' will be evaluated on every call to the receive()
method.
- Parameters:
connectionFactory
- keyExpression
-
setKeySerializer
public void setKeySerializer(org.springframework.data.redis.serializer.RedisSerializer<?> keySerializer)
setValueSerializer
public void setValueSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> valueSerializer)
setHashKeySerializer
public void setHashKeySerializer(org.springframework.data.redis.serializer.RedisSerializer<?> hashKeySerializer)
setHashValueSerializer
public void setHashValueSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> hashValueSerializer)
setCollectionType
public void setCollectionType(org.springframework.data.redis.support.collections.RedisCollectionFactoryBean.CollectionType collectionType)
receive
public Message<org.springframework.data.redis.support.collections.RedisStore> receive()
- Returns a Message with the view into a
RedisStore
identified
by keyExpression
- Specified by:
receive
in interface MessageSource<org.springframework.data.redis.support.collections.RedisStore>
onInit
protected void onInit()
throws java.lang.Exception
- Description copied from class:
IntegrationObjectSupport
- Subclasses may implement this for initialization logic.
- Overrides:
onInit
in class IntegrationObjectSupport
- Throws:
java.lang.Exception
getResource
public org.springframework.data.redis.support.collections.RedisStore getResource()
afterCommit
public void afterCommit(java.lang.Object object)
afterRollback
public void afterRollback(java.lang.Object object)