GH-1493 - Explicitly use JDK proxies for JdbcEventPublicationRepositoryV2.

Author: odrotbohm

spring-modulith-events/spring-modulith-events-jdbc/src/main/java/org/springframework/modulith/events/jdbc/JdbcEventPublicationAutoConfiguration.java

@@ -25,6 +25,8 @@
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.ProxyType;
+import org.springframework.context.annotation.Proxyable;
 import org.springframework.core.env.Environment;
 import org.springframework.core.io.ResourceLoader;
 import org.springframework.jdbc.core.JdbcTemplate;
@@ -60,6 +62,7 @@ JdbcRepositorySettings jdbcEventPublicationRepositorySettings(DatabaseType datab
 	}
 
 	@Bean
+	@Proxyable(ProxyType.INTERFACES)
 	EventPublicationRepository jdbcEventPublicationRepository(JdbcTemplate jdbcTemplate,
 			EventSerializer serializer, JdbcRepositorySettings settings) {
 

spring-modulith-events/spring-modulith-events-jdbc/src/test/java/org/springframework/modulith/events/jdbc/JdbcEventPublicationRepositoryIntegrationTests.java

@@ -33,10 +33,12 @@
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Nested;
 import org.junit.jupiter.api.Test;
+import org.springframework.aop.support.AopUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.jdbc.test.autoconfigure.JdbcTest;
 import org.springframework.context.annotation.Import;
 import org.springframework.jdbc.core.JdbcOperations;
+import org.springframework.modulith.events.core.EventPublicationRepository;
 import org.springframework.modulith.events.core.EventSerializer;
 import org.springframework.modulith.events.core.PublicationTargetIdentifier;
 import org.springframework.modulith.events.core.TargetEventPublication;
@@ -68,7 +70,7 @@ class JdbcEventPublicationRepositoryIntegrationTests {
 	static abstract class TestBase {
 
 		@Autowired JdbcOperations operations;
-		@Autowired JdbcEventPublicationRepository repository;
+		@Autowired EventPublicationRepository repository;
 		@Autowired JdbcRepositorySettings properties;
 
 		@MockitoBean EventSerializer serializer;
@@ -84,6 +86,11 @@ void cleanUp() {
 			}
 		}
 
+		@Test // GH-1493
+		void createsJdkProxyForRepository() {
+			assertThat(AopUtils.isJdkDynamicProxy(repository)).isTrue();
+		}
+
 		@Test // GH-3
 		void shouldPersistAndUpdateEventPublication() {
 

spring-modulith-events/spring-modulith-events-jdbc/src/test/java/org/springframework/modulith/events/jdbc/JdbcEventPublicationRepositoryV2IntegrationTests.java

@@ -33,11 +33,13 @@
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Nested;
 import org.junit.jupiter.api.Test;
+import org.springframework.aop.support.AopUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.jdbc.test.autoconfigure.JdbcTest;
 import org.springframework.context.annotation.Import;
 import org.springframework.jdbc.core.JdbcOperations;
 import org.springframework.modulith.events.EventPublication.Status;
+import org.springframework.modulith.events.core.EventPublicationRepository;
 import org.springframework.modulith.events.core.EventPublicationRepository.FailedCriteria;
 import org.springframework.modulith.events.core.EventSerializer;
 import org.springframework.modulith.events.core.PublicationTargetIdentifier;
@@ -68,7 +70,7 @@ class JdbcEventPublicationRepositoryV2IntegrationTests {
 	static abstract class TestBase {
 
 		@Autowired JdbcOperations operations;
-		@Autowired JdbcEventPublicationRepositoryV2 repository;
+		@Autowired EventPublicationRepository repository;
 		@Autowired JdbcRepositorySettings properties;
 
 		@MockitoBean EventSerializer serializer;
@@ -84,6 +86,11 @@ void cleanUp() {
 			}
 		}
 
+		@Test // GH-1493
+		void createsJdkProxyForRepository() {
+			assertThat(AopUtils.isJdkDynamicProxy(repository)).isTrue();
+		}
+
 		@Test // GH-3
 		void shouldPersistAndUpdateEventPublication() {