[Feature][api] AviatorFilterProcessorFactory renamed to FilterProcessorFactory.The Factory add supportsType method for supporting legency type of avaitor.

2 files changed, 8 insertions, 1 deletions

diff --git a/groot-api/src/main/java/com/geedgenetworks/api/factory/Factory.java b/groot-api/src/main/java/com/geedgenetworks/api/factory/Factory.java
index bd624a9..adba440 100644
--- a/groot-api/src/main/java/com/geedgenetworks/api/factory/Factory.java
+++ b/groot-api/src/main/java/com/geedgenetworks/api/factory/Factory.java
@@ -7,4 +7,11 @@ public interface Factory {
      * (e.g. {@code kafka-1}).
      */
     String type();
+
+    /**
+     * Returns true if the factory supports the given type.
+     */
+    boolean supportsType(String type);
+
+
 }
diff --git a/groot-api/src/main/java/com/geedgenetworks/api/factory/FactoryUtil.java b/groot-api/src/main/java/com/geedgenetworks/api/factory/FactoryUtil.java
index 22a14d3..f2f4a71 100644
--- a/groot-api/src/main/java/com/geedgenetworks/api/factory/FactoryUtil.java
+++ b/groot-api/src/main/java/com/geedgenetworks/api/factory/FactoryUtil.java
@@ -100,7 +100,7 @@ public final class FactoryUtil {
 
         final List<Factory> matchingFactories =
                 foundFactories.stream()
-                        .filter(f -> f.type().equals(type))
+                        .filter(f -> f.supportsType(type))
                         .collect(Collectors.toList());
 
         if (matchingFactories.isEmpty()) {