Tests for annotation lookups in interfaces (currently ignored for CGLIB proxies)

Issue: SPR-15271
Issue: SPR-14949
Issue: SPR-14322

Author: jhoeller

spring-aspects/src/test/java/org/springframework/transaction/aspectj/TransactionAspectTests.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2016 the original author or authors.
+ * Copyright 2002-2017 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -185,14 +185,15 @@ public Object performTransactionalOperation() throws Throwable {
 
 	/**
 	 * Note: resolution does not occur. Thus we can't make a class transactional if
-	 * it implements a transactionally annotated interface. This behaviour could only
+	 * it implements a transactionally annotated interface. This behavior could only
 	 * be changed in AbstractFallbackTransactionAttributeSource in Spring proper.
+	 * See SPR-14322.
 	 */
 	@Test
 	public void testDoesNotResolveTxAnnotationOnMethodFromClassImplementingAnnotatedInterface() throws Exception {
 		AnnotationTransactionAttributeSource atas = new AnnotationTransactionAttributeSource();
-		Method m = ImplementsAnnotatedInterface.class.getMethod("echo", Throwable.class);
-		TransactionAttribute ta = atas.getTransactionAttribute(m, ImplementsAnnotatedInterface.class);
+		Method method = ImplementsAnnotatedInterface.class.getMethod("echo", Throwable.class);
+		TransactionAttribute ta = atas.getTransactionAttribute(method, ImplementsAnnotatedInterface.class);
 		assertNull(ta);
 	}
 

spring-context/src/test/java/org/springframework/cache/CacheReproTests.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2016 the original author or authors.
+ * Copyright 2002-2017 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -21,6 +21,7 @@
 import java.util.List;
 import java.util.Optional;
 
+import org.junit.Ignore;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.rules.ExpectedException;
@@ -57,8 +58,9 @@ public class CacheReproTests {
 	@Rule
 	public final ExpectedException thrown = ExpectedException.none();
 
+
 	@Test
-	public void spr11124() throws Exception {
+	public void spr11124MultipleAnnotations() throws Exception {
 		AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(Spr11124Config.class);
 		Spr11124Service bean = context.getBean(Spr11124Service.class);
 		bean.single(2);
@@ -69,7 +71,7 @@ public void spr11124() throws Exception {
 	}
 
 	@Test
-	public void spr11249() throws Exception {
+	public void spr11249PrimitiveVarargs() throws Exception {
 		AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(Spr11249Config.class);
 		Spr11249Service bean = context.getBean(Spr11249Service.class);
 		Object result = bean.doSomething("op", 2, 3);
@@ -166,6 +168,31 @@ public void spr14853AdaptsToOptionalWithSync() {
 		assertSame(tb2, cache.get("tb1").get());
 	}
 
+	@Test
+	public void spr15271FindsOnInterfaceWithInterfaceProxy() {
+		AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(Spr15271ConfigA.class);
+		Spr15271Interface bean = context.getBean(Spr15271Interface.class);
+		Cache cache = context.getBean(CacheManager.class).getCache("itemCache");
+
+		TestBean tb = new TestBean("tb1");
+		bean.insertItem(tb);
+		assertSame(tb, bean.findById("tb1").get());
+		assertSame(tb, cache.get("tb1").get());
+	}
+
+	@Test @Ignore  // TODO
+	public void spr15271FindsOnInterfaceWithCglibProxy() {
+		AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(Spr15271ConfigB.class);
+		Spr15271Interface bean = context.getBean(Spr15271Interface.class);
+		Cache cache = context.getBean(CacheManager.class).getCache("itemCache");
+
+		TestBean tb = new TestBean("tb1");
+		bean.insertItem(tb);
+		assertSame(tb, bean.findById("tb1").get());
+		assertSame(tb, cache.get("tb1").get());
+	}
+
+
 	@Configuration
 	@EnableCaching
 	public static class Spr11124Config {
@@ -357,6 +384,7 @@ public Spr14230Service service() {
 		}
 	}
 
+
 	public static class Spr14853Service {
 
 		@Cacheable(value = "itemCache", sync = true)
@@ -371,6 +399,7 @@ public TestBean insertItem(TestBean item) {
 
 	}
 
+
 	@Configuration
 	@EnableCaching
 	public static class Spr14853Config {
@@ -386,4 +415,60 @@ public Spr14853Service service() {
 		}
 	}
 
+
+	public interface Spr15271Interface {
+
+		@Cacheable(value = "itemCache", sync = true)
+		Optional<TestBean> findById(String id);
+
+		@CachePut(cacheNames = "itemCache", key = "#item.name")
+		TestBean insertItem(TestBean item);
+	}
+
+
+	public static class Spr15271Service implements Spr15271Interface {
+
+		@Override
+		public Optional<TestBean> findById(String id) {
+			return Optional.of(new TestBean(id));
+		}
+
+		@Override
+		public TestBean insertItem(TestBean item) {
+			return item;
+		}
+	}
+
+
+	@Configuration
+	@EnableCaching
+	public static class Spr15271ConfigA {
+
+		@Bean
+		public CacheManager cacheManager() {
+			return new ConcurrentMapCacheManager();
+		}
+
+		@Bean
+		public Spr15271Interface service() {
+			return new Spr15271Service();
+		}
+	}
+
+
+	@Configuration
+	@EnableCaching(proxyTargetClass = true)
+	public static class Spr15271ConfigB {
+
+		@Bean
+		public CacheManager cacheManager() {
+			return new ConcurrentMapCacheManager();
+		}
+
+		@Bean
+		public Spr15271Interface service() {
+			return new Spr15271Service();
+		}
+	}
+
 }

spring-context/src/test/java/org/springframework/scheduling/annotation/EnableAsyncTests.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2016 the original author or authors.
+ * Copyright 2002-2017 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -25,6 +25,7 @@
 import java.util.concurrent.Executor;
 import java.util.concurrent.Future;
 
+import org.junit.Ignore;
 import org.junit.Test;
 import org.mockito.Mockito;
 
@@ -196,8 +197,32 @@ public void customExecutorIsPropagated() throws InterruptedException {
 
 		asyncBean.fail();
 		Thread.sleep(500);
-		Method m = ReflectionUtils.findMethod(AsyncBean.class, "fail");
-		exceptionHandler.assertCalledWith(m, UnsupportedOperationException.class);
+		Method method = ReflectionUtils.findMethod(AsyncBean.class, "fail");
+		exceptionHandler.assertCalledWith(method, UnsupportedOperationException.class);
+
+		ctx.close();
+	}
+
+	@Test
+	public void spr14949FindsOnInterfaceWithInterfaceProxy() throws InterruptedException {
+		AnnotationConfigApplicationContext ctx = new AnnotationConfigApplicationContext(Spr14949ConfigA.class);
+
+		AsyncInterface asyncBean = ctx.getBean(AsyncInterface.class);
+		asyncBean.work();
+		Thread.sleep(500);
+		assertThat(asyncBean.getThreadOfExecution().getName(), startsWith("Custom-"));
+
+		ctx.close();
+	}
+
+	@Test @Ignore  // TODO
+	public void spr14949FindsOnInterfaceWithCglibProxy() throws InterruptedException {
+		AnnotationConfigApplicationContext ctx = new AnnotationConfigApplicationContext(Spr14949ConfigB.class);
+
+		AsyncInterface asyncBean = ctx.getBean(AsyncInterface.class);
+		asyncBean.work();
+		Thread.sleep(500);
+		assertThat(asyncBean.getThreadOfExecution().getName(), startsWith("Custom-"));
 
 		ctx.close();
 	}
@@ -333,6 +358,28 @@ public AsyncBean asyncBean() {
 	}
 
 
+	@Configuration
+	@EnableAsync
+	static class AsyncWithExecutorQualifiedByNameConfig {
+
+		@Bean
+		public AsyncBeanWithExecutorQualifiedByName asyncBean() {
+			return new AsyncBeanWithExecutorQualifiedByName();
+		}
+
+		@Bean
+		public Executor e1() {
+			return new ThreadPoolTaskExecutor();
+		}
+
+		@Bean
+		@Qualifier("e2")
+		public Executor otherExecutor() {
+			return new ThreadPoolTaskExecutor();
+		}
+	}
+
+
 	@Configuration
 	@EnableAsync
 	static class CustomExecutorAsyncConfig implements AsyncConfigurer {
@@ -362,24 +409,75 @@ public AsyncUncaughtExceptionHandler exceptionHandler() {
 	}
 
 
+	public interface AsyncInterface {
+
+		@Async
+		void work();
+
+		Thread getThreadOfExecution();
+	}
+
+
+	public static class AsyncService implements AsyncInterface {
+
+		private Thread threadOfExecution;
+
+		@Override
+		public void work() {
+			this.threadOfExecution = Thread.currentThread();
+		}
+
+		@Override
+		public Thread getThreadOfExecution() {
+			return threadOfExecution;
+		}
+	}
+
+
 	@Configuration
 	@EnableAsync
-	static class AsyncWithExecutorQualifiedByNameConfig {
+	static class Spr14949ConfigA implements AsyncConfigurer {
 
 		@Bean
-		public AsyncBeanWithExecutorQualifiedByName asyncBean() {
-			return new AsyncBeanWithExecutorQualifiedByName();
+		public AsyncInterface asyncBean() {
+			return new AsyncService();
 		}
 
-		@Bean
-		public Executor e1() {
-			return new ThreadPoolTaskExecutor();
+		@Override
+		public Executor getAsyncExecutor() {
+			ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+			executor.setThreadNamePrefix("Custom-");
+			executor.initialize();
+			return executor;
 		}
 
+		@Override
+		public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
+			return null;
+		}
+	}
+
+
+	@Configuration
+	@EnableAsync(proxyTargetClass = true)
+	static class Spr14949ConfigB implements AsyncConfigurer {
+
 		@Bean
-		@Qualifier("e2")
-		public Executor otherExecutor() {
-			return new ThreadPoolTaskExecutor();
+		public AsyncInterface asyncBean() {
+			return new AsyncService();
+		}
+
+		@Override
+		public Executor getAsyncExecutor() {
+			ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+			executor.setThreadNamePrefix("Custom-");
+			executor.initialize();
+			return executor;
+		}
+
+		@Override
+		public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
+			return null;
 		}
 	}