diff --git a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/jooq/JooqAutoConfiguration.java b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/jooq/JooqAutoConfiguration.java index 491575b5886..d9f080c03e3 100644 --- a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/jooq/JooqAutoConfiguration.java +++ b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/jooq/JooqAutoConfiguration.java @@ -95,10 +95,12 @@ public class JooqAutoConfiguration { @Bean @ConditionalOnMissingBean(org.jooq.Configuration.class) public DefaultConfiguration jooqConfiguration(JooqProperties properties, ConnectionProvider connectionProvider, - DataSource dataSource, ObjectProvider configurationCustomizers) { + ObjectProvider executeListenerProviders, DataSource dataSource, + ObjectProvider configurationCustomizers) { DefaultConfiguration configuration = new DefaultConfiguration(); configuration.set(properties.determineSqlDialect(dataSource)); configuration.set(connectionProvider); + configuration.set(executeListenerProviders.orderedStream().toArray(ExecuteListenerProvider[]::new)); configurationCustomizers.orderedStream().forEach((customizer) -> customizer.customize(configuration)); return configuration; } @@ -110,7 +112,6 @@ public class JooqAutoConfiguration { ObjectProvider recordMapperProvider, ObjectProvider recordUnmapperProvider, ObjectProvider settings, ObjectProvider recordListenerProviders, - ObjectProvider executeListenerProviders, ObjectProvider visitListenerProviders, ObjectProvider transactionListenerProviders, ObjectProvider executorProvider) { @@ -121,7 +122,6 @@ public class JooqAutoConfiguration { settings.ifAvailable(configuration::set); executorProvider.ifAvailable(configuration::set); configuration.set(recordListenerProviders.orderedStream().toArray(RecordListenerProvider[]::new)); - configuration.set(executeListenerProviders.orderedStream().toArray(ExecuteListenerProvider[]::new)); configuration.set(visitListenerProviders.orderedStream().toArray(VisitListenerProvider[]::new)); configuration.setTransactionListenerProvider( transactionListenerProviders.orderedStream().toArray(TransactionListenerProvider[]::new));