diff --git a/spring-messaging/src/main/java/org/springframework/messaging/simp/config/AbstractMessageBrokerConfiguration.java b/spring-messaging/src/main/java/org/springframework/messaging/simp/config/AbstractMessageBrokerConfiguration.java
index 87286aaab6..50c9032972 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/simp/config/AbstractMessageBrokerConfiguration.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/simp/config/AbstractMessageBrokerConfiguration.java
@@ -254,6 +254,10 @@ public abstract class AbstractMessageBrokerConfiguration implements ApplicationC
 		});
 	}
 
+	private TaskExecutor defaultTaskExecutor() {
+		return new TaskExecutorRegistration().getTaskExecutor();
+	}
+
 	private static TaskExecutor getTaskExecutor(ChannelRegistration registration,
 			String threadNamePrefix, Supplier<TaskExecutor> fallback) {
 
@@ -261,10 +265,6 @@ public abstract class AbstractMessageBrokerConfiguration implements ApplicationC
 				executor -> setThreadNamePrefix(executor, threadNamePrefix));
 	}
 
-	private TaskExecutor defaultTaskExecutor() {
-		return new TaskExecutorRegistration().getTaskExecutor();
-	}
-
 	private static void setThreadNamePrefix(TaskExecutor taskExecutor, String name) {
 		if (taskExecutor instanceof CustomizableThreadCreator ctc) {
 			ctc.setThreadNamePrefix(name);
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/simp/config/ChannelRegistration.java b/spring-messaging/src/main/java/org/springframework/messaging/simp/config/ChannelRegistration.java
index e8f0626def..d2ef4bb1af 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/simp/config/ChannelRegistration.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/simp/config/ChannelRegistration.java
@@ -107,6 +107,7 @@ public class ChannelRegistration {
 	 * @param fallback a supplier of a fallback task executor in case none is configured
 	 * @param customizer further customizations
 	 * @return the task executor to use
+	 * @since 6.1.4
 	 */
 	protected TaskExecutor getTaskExecutor(Supplier<TaskExecutor> fallback, Consumer<TaskExecutor> customizer) {
 		if (this.executor != null) {