Add reproducer for transaction-aware cache error handling

Author: neiser

src/main/java/com/example/demo/CachingConfiguration.java

@@ -0,0 +1,27 @@
+package com.example.demo;
+
+import org.springframework.boot.autoconfigure.cache.RedisCacheManagerBuilderCustomizer;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.cache.annotation.CachingConfigurer;
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.cache.interceptor.CacheErrorHandler;
+import org.springframework.cache.interceptor.LoggingCacheErrorHandler;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.cache.RedisCacheManager;
+
+@Configuration(proxyBeanMethods = false)
+@EnableCaching
+public class CachingConfiguration implements CachingConfigurer {
+
+    @Bean
+    @ConditionalOnProperty(value = "makeRedisTransactionAware", matchIfMissing = true)
+    public RedisCacheManagerBuilderCustomizer transactionAwareRedisCacheManagerBuilderCustomizer() {
+        return RedisCacheManager.RedisCacheManagerBuilder::transactionAware;
+    }
+
+    @Override
+    public CacheErrorHandler errorHandler() {
+        return new LoggingCacheErrorHandler();
+    }
+}

src/main/java/com/example/demo/DemoApplication.java

@@ -2,8 +2,10 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
 
 @SpringBootApplication
+@EnableTransactionManagement
 public class DemoApplication {
 
 	public static void main(String[] args) {

src/main/java/com/example/demo/DemoController.java

@@ -0,0 +1,19 @@
+package com.example.demo;
+
+
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+@Component
+public class DemoController {
+    private final DemoRepository repository;
+
+    public DemoController(DemoRepository repository) {
+        this.repository = repository;
+    }
+
+    @Transactional
+    public String doSomething() {
+        return repository.doSomething();
+    }
+}

src/main/java/com/example/demo/DemoRepository.java

@@ -0,0 +1,12 @@
+package com.example.demo;
+
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.stereotype.Component;
+
+@Component
+public class DemoRepository {
+    @Cacheable("testCache")
+    public String doSomething() {
+        return "Value!";
+    }
+}

src/main/java/com/example/demo/TransactionConfiguration.java

@@ -0,0 +1,40 @@
+package com.example.demo;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.transaction.PlatformTransactionManager;
+import org.springframework.transaction.TransactionDefinition;
+import org.springframework.transaction.TransactionException;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
+import org.springframework.transaction.support.AbstractPlatformTransactionManager;
+import org.springframework.transaction.support.DefaultTransactionStatus;
+
+@Configuration(proxyBeanMethods = false)
+@EnableTransactionManagement
+public class TransactionConfiguration {
+
+    @Bean
+    public PlatformTransactionManager dummyTransactionManager() {
+        return new AbstractPlatformTransactionManager() {
+            @Override
+            protected Object doGetTransaction() throws TransactionException {
+                return new Object();
+            }
+
+            @Override
+            protected void doBegin(Object transaction, TransactionDefinition definition) throws TransactionException {
+                // do nothing
+            }
+
+            @Override
+            protected void doCommit(DefaultTransactionStatus status) throws TransactionException {
+                // do nothing
+            }
+
+            @Override
+            protected void doRollback(DefaultTransactionStatus status) throws TransactionException {
+                // do nothing
+            }
+        };
+    }
+}

src/main/resources/application.properties

@@ -0,0 +1,3 @@
+spring:
+  cache:
+    type: redis

src/main/resources/application.yaml

@@ -0,0 +1,20 @@
+package com.example.demo;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+import static org.assertj.core.api.Assertions.assertThatCode;
+
+@SpringBootTest
+class TestWithTransactionAwareness {
+
+	@Autowired
+	private DemoController demoController;
+
+	@Test
+	void doSomething() {
+		assertThatCode(demoController::doSomething).doesNotThrowAnyException();
+	}
+
+}

src/test/java/com/example/demo/DemoApplicationTests.java

@@ -0,0 +1,22 @@
+package com.example.demo;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.TestPropertySource;
+
+import static org.assertj.core.api.Assertions.assertThatCode;
+
+@SpringBootTest
+@TestPropertySource(properties = "makeRedisTransactionAware=false")
+class TestWithoutTransactionAwareness {
+
+    @Autowired
+    private DemoController demoController;
+
+    @Test
+    void doSomething() {
+        assertThatCode(demoController::doSomething).doesNotThrowAnyException();
+    }
+
+}