♻️ refactor: refactor codebase #2

Author: pnguyen215

plugin/src/main/groovy/org/redis4j/config/DefaultRedis4jCacheErrorConfig.java

@@ -0,0 +1,33 @@
+package org.redis4j.config;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.cache.Cache;
+import org.springframework.cache.interceptor.CacheErrorHandler;
+import org.springframework.stereotype.Component;
+
+@SuppressWarnings({"NullableProblems"})
+@Component
+public class DefaultRedis4jCacheErrorConfig implements CacheErrorHandler {
+    protected static final Logger logger = LoggerFactory.getLogger(DefaultRedis4jCacheErrorConfig.class);
+
+    @Override
+    public void handleCacheGetError(RuntimeException exception, Cache cache, Object key) {
+        logger.error("Redis4j, cache get error for key: {} in cache: {}", key, cache.getName(), exception);
+    }
+
+    @Override
+    public void handleCachePutError(RuntimeException exception, Cache cache, Object key, Object value) {
+        logger.error("Redis4j, cache put error for key: {} with value: {} in cache: {}", key, value, cache.getName(), exception);
+    }
+
+    @Override
+    public void handleCacheEvictError(RuntimeException exception, Cache cache, Object key) {
+        logger.error("Redis4j, cache evict error for key: {} in cache: {}", key, cache.getName(), exception);
+    }
+
+    @Override
+    public void handleCacheClearError(RuntimeException exception, Cache cache) {
+        logger.error("Redis4j, cache clear error in cache: {}", cache.getName(), exception);
+    }
+}

plugin/src/main/groovy/org/redis4j/config/DefaultRedis4jEventListenerConfig.java

@@ -0,0 +1,24 @@
+package org.redis4j.config;
+
+import io.lettuce.core.event.connection.ConnectionActivatedEvent;
+import io.lettuce.core.event.connection.ConnectionDeactivatedEvent;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.context.event.EventListener;
+
+//@Component
+public class DefaultRedis4jEventListenerConfig {
+    protected static final Logger logger = LoggerFactory.getLogger(DefaultRedis4jEventListenerConfig.class);
+
+    @EventListener
+    public void onConnectionActivated(ConnectionActivatedEvent event) {
+        logger.info("Connection activated event: {}", event.toString());
+        // drafting
+    }
+
+    @EventListener
+    public void onConnectionDeactivated(ConnectionDeactivatedEvent event) {
+        logger.error("Connection deactivated event: {}", event.toString());
+        // drafting
+    }
+}

plugin/src/main/groovy/org/redis4j/config/Redis4jConfig.java

@@ -1,11 +1,16 @@
 package org.redis4j.config;
 
+import io.lettuce.core.RedisClient;
+import io.lettuce.core.event.EventBus;
+import io.lettuce.core.resource.ClientResources;
+import io.lettuce.core.resource.DefaultClientResources;
 import org.redis4j.service.Redis4jConfigService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.cache.CacheManager;
 import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.cache.interceptor.CacheErrorHandler;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Primary;
@@ -23,11 +28,7 @@
 @Configuration
 @EnableCaching
 @EnableRedisRepositories
-@ConditionalOnProperty(
-        value = "spring.redis4j.enabled",
-        havingValue = "true",
-        matchIfMissing = false
-)
+@ConditionalOnProperty(value = "spring.redis4j.enabled", havingValue = "true", matchIfMissing = false)
 public class Redis4jConfig {
     protected final Redis4jConfigService redis4jConfigService;
 
@@ -88,4 +89,26 @@ public StringRedisTemplate stringRedisTemplate() {
     public CacheManager cacheManager() {
         return redis4jConfigService.createCacheManager(this.factory());
     }
+
+    @Bean
+    public ClientResources clientResources() {
+        return DefaultClientResources.create();
+    }
+
+    @Bean
+    public RedisClient redisClient() {
+        return RedisClient.create(clientResources());
+    }
+
+    @Bean
+    public EventBus eventBus() {
+        return clientResources().eventBus();
+    }
+
+    @Bean
+    @Primary
+    @ConditionalOnMissingBean(CacheErrorHandler.class)
+    public CacheErrorHandler errorHandler() {
+        return new DefaultRedis4jCacheErrorConfig();
+    }
 }