From 3d5a5ac3422485d88f093e067f7053cf3ad87f4e Mon Sep 17 00:00:00 2001
From: tjq <tengjiqi@gmail.com>
Date: Tue, 17 Jan 2023 23:18:14 +0800
Subject: [PATCH] feat: optimize code of PowerJobProcessorLoader

---
 .../powerjob/worker/processor/PowerJobProcessorLoader.java  | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/powerjob-worker/src/main/java/tech/powerjob/worker/processor/PowerJobProcessorLoader.java b/powerjob-worker/src/main/java/tech/powerjob/worker/processor/PowerJobProcessorLoader.java
index d73aad1d..eb2daad4 100644
--- a/powerjob-worker/src/main/java/tech/powerjob/worker/processor/PowerJobProcessorLoader.java
+++ b/powerjob-worker/src/main/java/tech/powerjob/worker/processor/PowerJobProcessorLoader.java
@@ -7,8 +7,10 @@ import tech.powerjob.worker.extension.processor.ProcessorBean;
 import tech.powerjob.worker.extension.processor.ProcessorDefinition;
 import tech.powerjob.worker.extension.processor.ProcessorFactory;
 
+import java.util.Collections;
 import java.util.List;
 import java.util.Map;
+import java.util.Optional;
 
 /**
  * PowerJobProcessorLoader
@@ -29,6 +31,10 @@ public class PowerJobProcessorLoader {
     public ProcessorBean load(ProcessorDefinition definition) {
         return def2Bean.computeIfAbsent(definition, ignore -> {
             for (ProcessorFactory pf : processorFactoryList) {
+
+                if (!Optional.ofNullable(pf.supportTypes()).orElse(Collections.emptySet()).contains(definition.getProcessorType())) {
+                    continue;
+                }
                 try {
                     ProcessorBean processorBean = pf.build(definition);
                     if (processorBean != null) {