A B C D G H I K M O P R S U Z 

A

afterCommit(Object) - Method in class org.springframework.integration.redis.inbound.RedisStoreMessageSource
 
afterRollback(Object) - Method in class org.springframework.integration.redis.inbound.RedisStoreMessageSource
 

B

buildBeanDefinition(Element, ParserContext) - Method in class org.springframework.integration.redis.config.RedisChannelParser
 

C

clearQueue() - Method in class org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint
Clear the Redis Queue specified by RedisQueueMessageDrivenEndpoint.boundListOperations.

D

DEFAULT_RECEIVE_TIMEOUT - Static variable in class org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint
 
DEFAULT_RECOVERY_INTERVAL - Static variable in class org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint
 
destroy() - Method in class org.springframework.integration.redis.channel.SubscribableRedisChannel
 
doListKeys(String) - Method in class org.springframework.integration.redis.store.RedisMessageStore
 
doParse(Element, ParserContext, String) - Method in class org.springframework.integration.redis.config.RedisInboundChannelAdapterParser
 
doParse(Element, ParserContext, String) - Method in class org.springframework.integration.redis.config.RedisQueueInboundChannelAdapterParser
 
doRemove(Object) - Method in class org.springframework.integration.redis.store.RedisMessageStore
 
doRetrieve(Object) - Method in class org.springframework.integration.redis.store.RedisMessageStore
 
doSend(Message<?>, long) - Method in class org.springframework.integration.redis.channel.SubscribableRedisChannel
 
doStart() - Method in class org.springframework.integration.redis.inbound.RedisInboundChannelAdapter
 
doStart() - Method in class org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint
 
doStop() - Method in class org.springframework.integration.redis.inbound.RedisInboundChannelAdapter
 
doStop() - Method in class org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint
 
doStore(Object, Object) - Method in class org.springframework.integration.redis.store.RedisMessageStore
 

G

get(String) - Method in class org.springframework.integration.redis.metadata.RedisMetadataStore
Retrieve the persisted value for the provided key.
getComponentType() - Method in class org.springframework.integration.redis.inbound.RedisInboundChannelAdapter
 
getComponentType() - Method in class org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint
 
getComponentType() - Method in class org.springframework.integration.redis.outbound.RedisQueueOutboundChannelAdapter
 
getComponentType() - Method in class org.springframework.integration.redis.outbound.RedisStoreWritingMessageHandler
 
getPhase() - Method in class org.springframework.integration.redis.channel.SubscribableRedisChannel
 
getQueueSize() - Method in class org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint
Returns the size of the Queue specified by RedisQueueMessageDrivenEndpoint.boundListOperations.
getResource() - Method in class org.springframework.integration.redis.inbound.RedisStoreMessageSource
 

H

handleMessageInternal(Message<?>) - Method in class org.springframework.integration.redis.outbound.RedisPublishingMessageHandler
 
handleMessageInternal(Message<?>) - Method in class org.springframework.integration.redis.outbound.RedisQueueOutboundChannelAdapter
 
handleMessageInternal(Message<?>) - Method in class org.springframework.integration.redis.outbound.RedisStoreWritingMessageHandler
Will extract the payload from the Message and store it in the collection identified by the key (which may be determined by an expression).

I

init() - Method in class org.springframework.integration.redis.config.RedisNamespaceHandler
 
isAutoStartup() - Method in class org.springframework.integration.redis.channel.SubscribableRedisChannel
 
isListening() - Method in class org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint
 
isRunning() - Method in class org.springframework.integration.redis.channel.SubscribableRedisChannel
 

K

KEY - Static variable in class org.springframework.integration.redis.metadata.RedisMetadataStore
 
KEY - Static variable in class org.springframework.integration.redis.support.RedisHeaders
 

M

MAP_KEY - Static variable in class org.springframework.integration.redis.support.RedisHeaders
 

O

onInit() - Method in class org.springframework.integration.redis.channel.SubscribableRedisChannel
 
onInit() - Method in class org.springframework.integration.redis.inbound.RedisInboundChannelAdapter
 
onInit() - Method in class org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint
 
onInit() - Method in class org.springframework.integration.redis.inbound.RedisStoreMessageSource
 
onInit() - Method in class org.springframework.integration.redis.outbound.RedisPublishingMessageHandler
 
onInit() - Method in class org.springframework.integration.redis.outbound.RedisStoreWritingMessageHandler
 
org.springframework.integration.redis.channel - package org.springframework.integration.redis.channel
Provides classes related to Redis-backed channels.
org.springframework.integration.redis.config - package org.springframework.integration.redis.config
Provides classes for configuration - parsers, namespace handlers.
org.springframework.integration.redis.event - package org.springframework.integration.redis.event
Events generated by the redis module
org.springframework.integration.redis.inbound - package org.springframework.integration.redis.inbound
Provides classes supporting inbound endpoints.
org.springframework.integration.redis.metadata - package org.springframework.integration.redis.metadata
Provides support for Redis-based MetadataStores.
org.springframework.integration.redis.outbound - package org.springframework.integration.redis.outbound
Provides classes supporting outbound endpoints.
org.springframework.integration.redis.store - package org.springframework.integration.redis.store
Provides classes related to the Redis message store.
org.springframework.integration.redis.support - package org.springframework.integration.redis.support
Provides supporting classes for this module.

P

parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.redis.config.RedisOutboundChannelAdapterParser
 
parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.redis.config.RedisQueueOutboundChannelAdapterParser
 
parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.redis.config.RedisStoreOutboundChannelAdapterParser
 
parseSource(Element, ParserContext) - Method in class org.springframework.integration.redis.config.RedisStoreInboundChannelAdapterParser
 
PREFIX - Static variable in class org.springframework.integration.redis.support.RedisHeaders
 
put(String, String) - Method in class org.springframework.integration.redis.metadata.RedisMetadataStore
Persists the provided key and value to Redis.

R

receive() - Method in class org.springframework.integration.redis.inbound.RedisStoreMessageSource
Returns a Message with the view into a RedisStore identified by RedisStoreMessageSource.keyExpression
RedisChannelParser - Class in org.springframework.integration.redis.config
Parser for the 'channel' and 'publish-subscribe-channel' elements of the Spring Integration Redis namespace.
RedisChannelParser() - Constructor for class org.springframework.integration.redis.config.RedisChannelParser
 
RedisExceptionEvent - Class in org.springframework.integration.redis.event
 
RedisExceptionEvent(Object, Throwable) - Constructor for class org.springframework.integration.redis.event.RedisExceptionEvent
 
RedisHeaders - Class in org.springframework.integration.redis.support
Pre-defined names and prefixes to be used for for dealing with headers required by Redis components
RedisHeaders() - Constructor for class org.springframework.integration.redis.support.RedisHeaders
 
RedisInboundChannelAdapter - Class in org.springframework.integration.redis.inbound
 
RedisInboundChannelAdapter(RedisConnectionFactory) - Constructor for class org.springframework.integration.redis.inbound.RedisInboundChannelAdapter
 
RedisInboundChannelAdapterParser - Class in org.springframework.integration.redis.config
 
RedisInboundChannelAdapterParser() - Constructor for class org.springframework.integration.redis.config.RedisInboundChannelAdapterParser
 
RedisIntegrationEvent - Class in org.springframework.integration.redis.event
 
RedisIntegrationEvent(Object) - Constructor for class org.springframework.integration.redis.event.RedisIntegrationEvent
 
RedisIntegrationEvent(Object, Throwable) - Constructor for class org.springframework.integration.redis.event.RedisIntegrationEvent
 
RedisMessageStore - Class in org.springframework.integration.redis.store
Redis implementation of the key/value style MessageStore and MessageGroupStore
RedisMessageStore(RedisConnectionFactory) - Constructor for class org.springframework.integration.redis.store.RedisMessageStore
 
RedisMetadataStore - Class in org.springframework.integration.redis.metadata
Redis implementation of MetadataStore.
RedisMetadataStore(RedisProperties) - Constructor for class org.springframework.integration.redis.metadata.RedisMetadataStore
Specifies the RedisProperties backend for this MetadataStore.
RedisMetadataStore(RedisConnectionFactory) - Constructor for class org.springframework.integration.redis.metadata.RedisMetadataStore
Initializes the RedisProperties by provided RedisConnectionFactory and default hash key - RedisMetadataStore.KEY.
RedisMetadataStore(RedisConnectionFactory, String) - Constructor for class org.springframework.integration.redis.metadata.RedisMetadataStore
Initializes the RedisProperties by provided RedisConnectionFactory and key.
RedisMetadataStore(RedisOperations<String, ?>) - Constructor for class org.springframework.integration.redis.metadata.RedisMetadataStore
Initializes the RedisProperties by provided RedisConnectionFactory and default hash key - RedisMetadataStore.KEY.
RedisMetadataStore(RedisOperations<String, ?>, String) - Constructor for class org.springframework.integration.redis.metadata.RedisMetadataStore
Initializes the RedisProperties by provided RedisConnectionFactory and key.
RedisNamespaceHandler - Class in org.springframework.integration.redis.config
Namespace handler for Spring Integration's 'redis' namespace.
RedisNamespaceHandler() - Constructor for class org.springframework.integration.redis.config.RedisNamespaceHandler
 
RedisOutboundChannelAdapterParser - Class in org.springframework.integration.redis.config
Parser for the <outbound-channel-adapter/> component.
RedisOutboundChannelAdapterParser() - Constructor for class org.springframework.integration.redis.config.RedisOutboundChannelAdapterParser
 
RedisPublishingMessageHandler - Class in org.springframework.integration.redis.outbound
 
RedisPublishingMessageHandler(RedisConnectionFactory) - Constructor for class org.springframework.integration.redis.outbound.RedisPublishingMessageHandler
 
RedisQueueInboundChannelAdapterParser - Class in org.springframework.integration.redis.config
Parser for the <queue-inbound-channel-adapter> element of the 'redis' namespace.
RedisQueueInboundChannelAdapterParser() - Constructor for class org.springframework.integration.redis.config.RedisQueueInboundChannelAdapterParser
 
RedisQueueMessageDrivenEndpoint - Class in org.springframework.integration.redis.inbound
 
RedisQueueMessageDrivenEndpoint(String, RedisConnectionFactory) - Constructor for class org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint
 
RedisQueueOutboundChannelAdapter - Class in org.springframework.integration.redis.outbound
 
RedisQueueOutboundChannelAdapter(String, RedisConnectionFactory) - Constructor for class org.springframework.integration.redis.outbound.RedisQueueOutboundChannelAdapter
 
RedisQueueOutboundChannelAdapter(Expression, RedisConnectionFactory) - Constructor for class org.springframework.integration.redis.outbound.RedisQueueOutboundChannelAdapter
 
RedisQueueOutboundChannelAdapterParser - Class in org.springframework.integration.redis.config
Parser for the <int-redis:queue-outbound-channel-adapter> element.
RedisQueueOutboundChannelAdapterParser() - Constructor for class org.springframework.integration.redis.config.RedisQueueOutboundChannelAdapterParser
 
RedisStoreInboundChannelAdapterParser - Class in org.springframework.integration.redis.config
Parser for Redis store inbound adapters
RedisStoreInboundChannelAdapterParser() - Constructor for class org.springframework.integration.redis.config.RedisStoreInboundChannelAdapterParser
 
RedisStoreMessageSource - Class in org.springframework.integration.redis.inbound
Inbound channel adapter which returns a Message representing a view into a Redis store.
RedisStoreMessageSource(RedisTemplate<String, ?>, Expression) - Constructor for class org.springframework.integration.redis.inbound.RedisStoreMessageSource
Creates an instance with the provided RedisTemplate and SpEL expression which should resolve to a 'key' name of the collection to be used.
RedisStoreMessageSource(RedisConnectionFactory, Expression) - Constructor for class org.springframework.integration.redis.inbound.RedisStoreMessageSource
Creates an instance with the provided RedisConnectionFactory and SpEL expression which should resolve to a 'key' name of the collection to be used.
RedisStoreOutboundChannelAdapterParser - Class in org.springframework.integration.redis.config
Parser for the <redis:store-outbound-channel-adapter> element.
RedisStoreOutboundChannelAdapterParser() - Constructor for class org.springframework.integration.redis.config.RedisStoreOutboundChannelAdapterParser
 
RedisStoreWritingMessageHandler - Class in org.springframework.integration.redis.outbound
Implementation of MessageHandler which writes Message data into a Redis store identified by a key String.
RedisStoreWritingMessageHandler(RedisTemplate<String, ?>) - Constructor for class org.springframework.integration.redis.outbound.RedisStoreWritingMessageHandler
Constructs an instance using the provided RedisTemplate.
RedisStoreWritingMessageHandler(RedisConnectionFactory) - Constructor for class org.springframework.integration.redis.outbound.RedisStoreWritingMessageHandler
Constructs an instance using the provided RedisConnectionFactory.
remove(String) - Method in class org.springframework.integration.redis.metadata.RedisMetadataStore
 

S

setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint
 
setCollectionType(RedisCollectionFactoryBean.CollectionType) - Method in class org.springframework.integration.redis.inbound.RedisStoreMessageSource
 
setCollectionType(RedisCollectionFactoryBean.CollectionType) - Method in class org.springframework.integration.redis.outbound.RedisStoreWritingMessageHandler
Sets the collection type for this handler as per RedisCollectionFactoryBean.CollectionType.
setDefaultTopic(String) - Method in class org.springframework.integration.redis.outbound.RedisPublishingMessageHandler
setErrorChannel(MessageChannel) - Method in class org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint
 
setExpectMessage(boolean) - Method in class org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint
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?.
setExtractPayload(boolean) - Method in class org.springframework.integration.redis.outbound.RedisQueueOutboundChannelAdapter
 
setExtractPayloadElements(boolean) - Method in class org.springframework.integration.redis.outbound.RedisStoreWritingMessageHandler
Sets the flag signifying that if the payload is a "multivalue" (i.e., Collection or Map), it should be saved using addAll/putAll semantics.
setIntegrationEvaluationContext(EvaluationContext) - Method in class org.springframework.integration.redis.outbound.RedisPublishingMessageHandler
 
setIntegrationEvaluationContext(EvaluationContext) - Method in class org.springframework.integration.redis.outbound.RedisQueueOutboundChannelAdapter
 
setKey(String) - Method in class org.springframework.integration.redis.outbound.RedisStoreWritingMessageHandler
Specifies the key for the Redis store.
setKeyExpression(Expression) - Method in class org.springframework.integration.redis.outbound.RedisStoreWritingMessageHandler
Specifies a SpEL Expression to be used to determine the key for the Redis store.
setMapKeyExpression(Expression) - Method in class org.springframework.integration.redis.outbound.RedisStoreWritingMessageHandler
Sets the expression used as the key for Map and Properties entries.
setMaxSubscribers(int) - Method in class org.springframework.integration.redis.channel.SubscribableRedisChannel
Specify the maximum number of subscribers supported by the channel's dispatcher.
setMessageConverter(MessageConverter) - Method in class org.springframework.integration.redis.channel.SubscribableRedisChannel
 
setMessageConverter(MessageConverter) - Method in class org.springframework.integration.redis.inbound.RedisInboundChannelAdapter
 
setMessageConverter(MessageConverter) - Method in class org.springframework.integration.redis.outbound.RedisPublishingMessageHandler
 
setReceiveTimeout(long) - Method in class org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint
This timeout (milliseconds) is used when retrieving elements from the queue specified by RedisQueueMessageDrivenEndpoint.boundListOperations.
setRecoveryInterval(long) - Method in class org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint
 
setSerializer(RedisSerializer<?>) - Method in class org.springframework.integration.redis.channel.SubscribableRedisChannel
 
setSerializer(RedisSerializer<?>) - Method in class org.springframework.integration.redis.inbound.RedisInboundChannelAdapter
 
setSerializer(RedisSerializer<?>) - Method in class org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint
 
setSerializer(RedisSerializer<?>) - Method in class org.springframework.integration.redis.outbound.RedisPublishingMessageHandler
 
setSerializer(RedisSerializer<?>) - Method in class org.springframework.integration.redis.outbound.RedisQueueOutboundChannelAdapter
 
setTaskExecutor(Executor) - Method in class org.springframework.integration.redis.channel.SubscribableRedisChannel
 
setTaskExecutor(Executor) - Method in class org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint
 
setTopic(String) - Method in class org.springframework.integration.redis.outbound.RedisPublishingMessageHandler
 
setTopicExpression(Expression) - Method in class org.springframework.integration.redis.outbound.RedisPublishingMessageHandler
 
setTopicPatterns(String...) - Method in class org.springframework.integration.redis.inbound.RedisInboundChannelAdapter
 
setTopics(String...) - Method in class org.springframework.integration.redis.inbound.RedisInboundChannelAdapter
 
setValueSerializer(RedisSerializer<?>) - Method in class org.springframework.integration.redis.store.RedisMessageStore
 
start() - Method in class org.springframework.integration.redis.channel.SubscribableRedisChannel
 
stop() - Method in class org.springframework.integration.redis.channel.SubscribableRedisChannel
 
stop(Runnable) - Method in class org.springframework.integration.redis.channel.SubscribableRedisChannel
 
SubscribableRedisChannel - Class in org.springframework.integration.redis.channel
 
SubscribableRedisChannel(RedisConnectionFactory, String) - Constructor for class org.springframework.integration.redis.channel.SubscribableRedisChannel
 
subscribe(MessageHandler) - Method in class org.springframework.integration.redis.channel.SubscribableRedisChannel
 

U

unsubscribe(MessageHandler) - Method in class org.springframework.integration.redis.channel.SubscribableRedisChannel
 

Z

ZSET_INCREMENT_SCORE - Static variable in class org.springframework.integration.redis.support.RedisHeaders
 
ZSET_SCORE - Static variable in class org.springframework.integration.redis.support.RedisHeaders
 
A B C D G H I K M O P R S U Z