Class RedisStoreMessageSource
java.lang.Object
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.endpoint.AbstractMessageSource<org.springframework.data.redis.support.collections.RedisStore>
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.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.integration.core.MessageSource<org.springframework.data.redis.support.collections.RedisStore>,org.springframework.integration.IntegrationPattern,org.springframework.integration.support.context.NamedComponent,org.springframework.integration.support.management.IntegrationInboundManagement,org.springframework.integration.support.management.IntegrationManagement
public class RedisStoreMessageSource
extends org.springframework.integration.endpoint.AbstractMessageSource<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
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement
org.springframework.integration.support.management.IntegrationManagement.ManagementOverrides -
Field Summary
Fields inherited from class org.springframework.integration.util.AbstractExpressionEvaluator
EXPRESSION_PARSER, loggerFields inherited from interface org.springframework.integration.support.management.IntegrationManagement
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME -
Constructor Summary
ConstructorsConstructorDescriptionRedisStoreMessageSource(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory, org.springframework.expression.Expression keyExpression) Creates an instance with the providedRedisConnectionFactoryand SpEL expression which should resolve to a 'key' name of the collection to be used.RedisStoreMessageSource(org.springframework.data.redis.core.RedisTemplate<String, ?> redisTemplate, org.springframework.expression.Expression keyExpression) Creates an instance with the providedRedisTemplateand SpEL expression which should resolve to a 'key' name of the collection to be used. -
Method Summary
Modifier and TypeMethodDescriptionvoidafterCommit(Object object) voidafterRollback(Object object) protected org.springframework.data.redis.support.collections.RedisStoreReturns a Message with the view into aRedisStoreidentified bykeyExpressionorg.springframework.data.redis.support.collections.RedisStoreprotected voidonInit()voidsetCollectionType(org.springframework.data.redis.support.collections.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, setManagedTypeMethods inherited from class org.springframework.integration.util.AbstractExpressionEvaluator
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionServiceMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.springframework.integration.support.management.IntegrationManagement
getThisAs, registerObservationRegistryMethods inherited from interface org.springframework.integration.core.MessageSource
getIntegrationPatternType
-
Constructor Details
-
RedisStoreMessageSource
public RedisStoreMessageSource(org.springframework.data.redis.core.RedisTemplate<String, ?> redisTemplate, org.springframework.expression.Expression keyExpression) Creates an instance with the providedRedisTemplateand SpEL expression which should resolve to a 'key' name of the collection to be used. It assumes thatRedisTemplateis fully initialized and ready to be used. The 'keyExpression' will be evaluated on every call to theAbstractMessageSource.receive()method.- Parameters:
redisTemplate- The Redis template.keyExpression- The key expression.
-
RedisStoreMessageSource
public RedisStoreMessageSource(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory, org.springframework.expression.Expression keyExpression) Creates an instance with the providedRedisConnectionFactoryand SpEL expression which should resolve to a 'key' name of the collection to be used. It will create and initialize an instance ofStringRedisTemplatethat usesStringRedisSerializerfor all serialization. The 'keyExpression' will be evaluated on every call to theAbstractMessageSource.receive()method.- Parameters:
connectionFactory- The connection factory.keyExpression- The key expression.
-
-
Method Details
-
setCollectionType
public void setCollectionType(org.springframework.data.redis.support.collections.RedisCollectionFactoryBean.CollectionType collectionType) -
onInit
protected void onInit()- Overrides:
onInitin classorg.springframework.integration.util.AbstractExpressionEvaluator
-
doReceive
protected org.springframework.data.redis.support.collections.RedisStore doReceive()Returns a Message with the view into aRedisStoreidentified bykeyExpression- Specified by:
doReceivein classorg.springframework.integration.endpoint.AbstractMessageSource<org.springframework.data.redis.support.collections.RedisStore>
-
getComponentType
-
getResource
public org.springframework.data.redis.support.collections.RedisStore getResource() -
afterCommit
-
afterRollback
-