From 67958656e47220627948774d8f8e9cf712a1064a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?St=C3=A9phane=20Nicoll?= Date: Wed, 31 Jan 2024 11:50:18 +0100 Subject: [PATCH] Polish --- .../simp/config/AbstractMessageBrokerConfiguration.java | 8 ++++---- .../messaging/simp/config/ChannelRegistration.java | 1 + 2 files changed, 5 insertions(+), 4 deletions(-) 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 87286aaab6d..50c90329723 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 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 e8f0626def7..d2ef4bb1afa 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 fallback, Consumer customizer) { if (this.executor != null) {