diff --git a/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/lock/DefaultLockRepository.java b/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/lock/DefaultLockRepository.java index e442a6d125..162d160a30 100644 --- a/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/lock/DefaultLockRepository.java +++ b/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/lock/DefaultLockRepository.java @@ -1,5 +1,5 @@ /* - * Copyright 2016-2024 the original author or authors. + * Copyright 2016-2025 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. @@ -305,6 +305,19 @@ public class DefaultLockRepository return this.renewQuery; } + /** + * The flag to perform a database check query on start or not. + * @param checkDatabaseOnStart false to not perform the database check. + * @since 6.2 + */ + public void setCheckDatabaseOnStart(boolean checkDatabaseOnStart) { + this.checkDatabaseOnStart = checkDatabaseOnStart; + if (!checkDatabaseOnStart) { + LOGGER.info("The 'DefaultLockRepository' won't be started automatically " + + "and required table is not going be checked."); + } + } + @Override public void afterPropertiesSet() { this.deleteQuery = String.format(this.deleteQuery, this.prefix); @@ -347,19 +360,6 @@ public class DefaultLockRepository this.readCommittedTransactionTemplate = new TransactionTemplate(this.transactionManager, transactionDefinition); } - /** - * The flag to perform a database check query on start or not. - * @param checkDatabaseOnStart false to not perform the database check. - * @since 6.2 - */ - public void setCheckDatabaseOnStart(boolean checkDatabaseOnStart) { - this.checkDatabaseOnStart = checkDatabaseOnStart; - if (!checkDatabaseOnStart) { - LOGGER.info("The 'DefaultLockRepository' won't be started automatically " + - "and required table is not going be checked."); - } - } - @Override public boolean isAutoStartup() { return this.checkDatabaseOnStart; diff --git a/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/metadata/JdbcMetadataStore.java b/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/metadata/JdbcMetadataStore.java index ec03945c11..478e92e35a 100644 --- a/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/metadata/JdbcMetadataStore.java +++ b/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/metadata/JdbcMetadataStore.java @@ -1,5 +1,5 @@ /* - * Copyright 2017-2024 the original author or authors. + * Copyright 2017-2025 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. @@ -193,7 +193,7 @@ public class JdbcMetadataStore implements ConcurrentMetadataStore, InitializingB public void setCheckDatabaseOnStart(boolean checkDatabaseOnStart) { this.checkDatabaseOnStart = checkDatabaseOnStart; if (!checkDatabaseOnStart) { - LOGGER.info("The 'DefaultLockRepository' won't be started automatically " + + LOGGER.info("The 'JdbcMetadataStore' won't be started automatically " + "and required table is not going be checked."); } } diff --git a/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/store/JdbcChannelMessageStore.java b/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/store/JdbcChannelMessageStore.java index 9261f02f14..4dbf98c02c 100644 --- a/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/store/JdbcChannelMessageStore.java +++ b/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/store/JdbcChannelMessageStore.java @@ -431,7 +431,7 @@ public class JdbcChannelMessageStore implements PriorityCapableChannelMessageSto public void setCheckDatabaseOnStart(boolean checkDatabaseOnStart) { this.checkDatabaseOnStart = checkDatabaseOnStart; if (!checkDatabaseOnStart) { - LOGGER.info("The 'DefaultLockRepository' won't be started automatically " + + LOGGER.info("The 'JdbcChannelMessageStore' won't be started automatically " + "and required table is not going be checked."); } } diff --git a/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/store/JdbcMessageStore.java b/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/store/JdbcMessageStore.java index 0bd914510d..0755506603 100644 --- a/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/store/JdbcMessageStore.java +++ b/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/store/JdbcMessageStore.java @@ -368,7 +368,7 @@ public class JdbcMessageStore extends AbstractMessageGroupStore public void setCheckDatabaseOnStart(boolean checkDatabaseOnStart) { this.checkDatabaseOnStart = checkDatabaseOnStart; if (!checkDatabaseOnStart) { - logger.info("The 'DefaultLockRepository' won't be started automatically " + + logger.info("The 'JdbcMessageStore' won't be started automatically " + "and required table is not going be checked."); } }