Resolve TaskExecutor bean conflict

Spring Boot 3 resolves TaskExecutor beans more strictly. Explicit bean naming avoids ambiguity with TaskScheduler.

Author: Domonkos Gulyas

src/main/java/org/phoebus/channelfinder/Application.java

@@ -119,7 +119,7 @@ public List<ChannelProcessor> channelProcessors() {
    *
    * @return A {@link TaskExecutor}
    */
-  @Bean
+  @Bean("channelFinderTaskExecutor")
   public TaskExecutor taskExecutor() {
     ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
     taskExecutor.setCorePoolSize(3);

src/main/java/org/phoebus/channelfinder/service/ChannelProcessorService.java

@@ -12,6 +12,7 @@
 import org.phoebus.channelfinder.entity.Channel;
 import org.phoebus.channelfinder.service.model.archiver.ChannelProcessorInfo;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.core.task.TaskExecutor;
 import org.springframework.stereotype.Service;
@@ -23,16 +24,16 @@ public class ChannelProcessorService {
 
   private final List<ChannelProcessor> channelProcessors;
 
-  private final TaskExecutor taskExecutor;
+  private final TaskExecutor channelFinderTaskExecutor;
 
   private final int chunkSize;
 
   public ChannelProcessorService(
       @Autowired List<ChannelProcessor> channelProcessors,
-      @Autowired TaskExecutor taskExecutor,
+      @Autowired @Qualifier("channelFinderTaskExecutor") TaskExecutor channelFinderTaskExecutor,
       @Value("${processors.chunking.size:10000}") int chunkSize) {
     this.channelProcessors = channelProcessors;
-    this.taskExecutor = taskExecutor;
+    this.channelFinderTaskExecutor = channelFinderTaskExecutor;
     this.chunkSize = chunkSize;
   }
 
@@ -66,7 +67,7 @@ public void sendToProcessors(List<Channel> channels) {
     if (channelProcessors.isEmpty()) {
       return;
     }
-    taskExecutor.execute(
+    channelFinderTaskExecutor.execute(
         () ->
             channelProcessors.stream()
                 .filter(ChannelProcessor::enabled)