remove pipeline bus v1 (#16895)

elastic · Jan 10, 2025 · 348f162 · 348f162
1 parent 356ecb3
commit 348f162
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 247 deletions.
diff --git a/logstash-core/src/main/java/org/logstash/plugins/pipeline/PipelineBus.java b/logstash-core/src/main/java/org/logstash/plugins/pipeline/PipelineBus.java
@@ -43,14 +43,7 @@ public interface PipelineBus {
      * @return a new pipeline bus
      */
     static PipelineBus create() {
-        final String pipelineBusImplementation = System.getProperty("logstash.pipelinebus.implementation", "v2");
-        switch (pipelineBusImplementation) {
-            case "v1": return new PipelineBusV1();
-            case "v2": return new PipelineBusV2();
-            default:
-                LOGGER.warn("unknown pipeline-bus implementation: {}", pipelineBusImplementation);
-                return new PipelineBusV1();
-        }
+        return new PipelineBusV2();
     }
 
     /**

diff --git a/logstash-core/src/main/java/org/logstash/plugins/pipeline/PipelineBusV1.java b/logstash-core/src/main/java/org/logstash/plugins/pipeline/PipelineBusV1.java
diff --git a/logstash-core/src/test/java/org/logstash/plugins/pipeline/PipelineBusTest.java b/logstash-core/src/test/java/org/logstash/plugins/pipeline/PipelineBusTest.java
@@ -53,7 +53,7 @@ public class PipelineBusTest {
 
     @Parameterized.Parameters(name = "{0}")
     public static Collection<Class<? extends PipelineBus.Testable>> data() {
-        return Set.of(PipelineBusV1.Testable.class, PipelineBusV2.Testable.class);
+        return Set.of(PipelineBusV2.Testable.class);
     }
 
     @Parameterized.Parameter