Skip to content

Commit

Permalink
feat: redisson config
Browse files Browse the repository at this point in the history
  • Loading branch information
ohksj77 committed Oct 16, 2023
1 parent b0dda53 commit 88c5927
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.redisson.spring.data.connection.RedissonConnectionFactory;
import org.springframework.cache.CacheManager;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
Expand Down Expand Up @@ -38,28 +39,28 @@ public class RedisConfig {

@Bean
public RedissonClient redissonClient() {
Config config = new Config();
final Config config = new Config();
config.useSingleServer().setAddress(REDISSON_HOST_PREFIX + redisProperties.getHost() + URL_DELIMITER + redisProperties.getPort());
return Redisson.create(config);
}

@Bean
public RedisConnectionFactory redisConnectionFactory() {
return new LettuceConnectionFactory(redisProperties.getHost(), redisProperties.getPort());
return new RedissonConnectionFactory(redissonClient());
}

@Bean
public RedisTemplate<?, ?> redisTemplate() {
RedisTemplate<byte[], byte[]> redisTemplate = new RedisTemplate<>();
final RedisTemplate<byte[], byte[]> redisTemplate = new RedisTemplate<>();
redisTemplate.setConnectionFactory(redisConnectionFactory());
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setEnableTransactionSupport(false);
return redisTemplate;
}

@Bean
public CacheManager cacheManager(RedisConnectionFactory cf) {
RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
public CacheManager cacheManager(final RedisConnectionFactory cf) {
final RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer()))
.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new GenericJackson2JsonRedisSerializer()))
.entryTtl(Duration.ofHours(TIME_TO_LIVE));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,10 +53,10 @@ public void sendDeadLetter(final DeadLetter deadLetter) throws MessagingExceptio
}

private String getDeadLetterText(final DeadLetter deadLetter) {
final String content = "topic-name" + deadLetter.getTopicName()
+ "key-name" + deadLetter.getKeyName()
+ "time" + deadLetter.getBaseTime().getCreatedAt()
+ "payload" + deadLetter.getValueObject();
final String content = "topic-name : " + deadLetter.getTopicName() + "\n"
+ "key-name : " + deadLetter.getKeyName() + "\n"
+ "time : " + deadLetter.getBaseTime().getCreatedAt() + "\n"
+ "payload : " + deadLetter.getValueObject();

return String.format(DEAD_LETTER_CONTENT, content);
}
Expand Down

0 comments on commit 88c5927

Please sign in to comment.