Skip to content

Instantly share code, notes, and snippets.

@warpgate3
Created September 9, 2019 07:06
Show Gist options
  • Save warpgate3/434ed38b12f07b221d58333f3c6d1223 to your computer and use it in GitHub Desktop.
Save warpgate3/434ed38b12f07b221d58333f3c6d1223 to your computer and use it in GitHub Desktop.
package info.m2sj.springfluxandredis;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.ReactiveRedisConnectionFactory;
import org.springframework.data.redis.core.ReactiveRedisOperations;
import org.springframework.data.redis.core.ReactiveRedisTemplate;
import org.springframework.data.redis.serializer.RedisSerializationContext;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
@Configuration
public class BasicRedisConfig {
@Bean
ReactiveRedisOperations<String, String> redisOperations(ReactiveRedisConnectionFactory factory) {
RedisSerializer<String> serializer = new StringRedisSerializer();
RedisSerializationContext<String, String> serializationContext = RedisSerializationContext
.<String, String>newSerializationContext()
.key(serializer)
.value(serializer)
.hashKey(serializer)
.hashValue(serializer)
.build();
return new ReactiveRedisTemplate<>(factory,
serializationContext);
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment