JvmInitializers { public static void runBeforeProcessing(PipelineOptions options) { for (JvmInitializer initializer : ReflectHelpers.loadServicesOrdered(JvmInitializer.class)) { initializer.beforeProcessing(options); } }  static void runOnStartup(); static void runBeforeProcessing(PipelineOptions options);  }
@Test public void runBeforeProcessing_runsInitializersWithOptions() { PipelineOptions options = TestPipeline.testingPipelineOptions(); JvmInitializers.runBeforeProcessing(options); assertTrue(beforeProcessingRan); assertEquals(options, receivedOptions); }