org.springframework.cloud.stream.app.redis.sink

Class RedisSinkConfiguration

java.lang.Object

org.springframework.cloud.stream.app.redis.sink.RedisSinkConfiguration

@Configuration
 @EnableConfigurationProperties(value=RedisSinkProperties.class)
 @EnableBinding(value=org.springframework.cloud.stream.messaging.Sink.class)
public class RedisSinkConfiguration
extends Object

Creates a dedicated RedisConnectionFactory different from the one spring-boot autoconfigure section that the bindings use in spring-cloud-stream.

The configuration prefix is "spring.cloud.stream.module.redis" and contains the standard properties to configure a redis connection, host, port, etc as well as the additional properties for the sink, queue, key, etc.

Author:

Eric Bottard, Mark Pollack, Gary Russell

Constructor Summary

Constructors

Constructor and Description
RedisSinkConfiguration()

Method Summary

Modifier and Type	Method and Description
org.springframework.messaging.MessageHandler	redisSinkMessageHandler()

Methods inherited from class java.lang.Object

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

Constructor Detail

RedisSinkConfiguration

public RedisSinkConfiguration()

Method Detail

redisSinkMessageHandler

@Bean
 @ServiceActivator(inputChannel="input")
public org.springframework.messaging.MessageHandler redisSinkMessageHandler()