Apply conceptually modification (internal, external and bridge processor) changes.

Author: mashhurs

src/main/java/co/elastic/logstash/filters/elasticintegration/geoip/GeoIpProcessorFactory.java

@@ -24,10 +24,10 @@ public ProcessorBridge create(Map<String, ProcessorBridge.Factory> processorFact
                             String tag,
                             String description,
                             Map<String, Object> config) throws Exception {
-        return ProcessorBridge.wrap(new GeoIpProcessor.Factory("geoip", this.ipDatabaseProvider)
+        return ProcessorBridge.fromInternal(new GeoIpProcessor.Factory("geoip", this.ipDatabaseProvider)
                 .create(processorFactories.entrySet()
                                 .stream()
-                                .collect(Collectors.toMap(Map.Entry::getKey,e -> e.getValue().unwrap())),
+                                .collect(Collectors.toMap(Map.Entry::getKey,e -> e.getValue().toInternal())),
                         tag,
                         description,
                         config,

src/main/java/co/elastic/logstash/filters/elasticintegration/ingest/PipelineProcessor.java

@@ -17,7 +17,7 @@
 import java.util.Map;
 import java.util.function.BiConsumer;
 
-public class PipelineProcessor implements ProcessorBridge {
+public class PipelineProcessor extends ProcessorBridge.AbstractExternal {
     public static final String TYPE = "pipeline";
 
     private final String tag;

src/main/java/co/elastic/logstash/filters/elasticintegration/ingest/SetSecurityUserProcessor.java

@@ -12,7 +12,7 @@
 import java.util.Map;
 import java.util.function.BiConsumer;
 
-public class SetSecurityUserProcessor implements ProcessorBridge {
+public class SetSecurityUserProcessor extends ProcessorBridge.AbstractExternal {
 
     public static final String TYPE = "set_security_user";
     private final String tag;