public static void runBeforeProcessing(PipelineOptions options) {
    // We load the logger in the method to minimize the amount of class loading that happens
    // during class initialization.
    Logger logger = LoggerFactory.getLogger(JvmInitializers.class);
    for (JvmInitializer initializer : ReflectHelpers.loadServicesOrdered(JvmInitializer.class)) {
      logger.info("Running JvmInitializer#beforeProcessing for {}", initializer);
      initializer.beforeProcessing(options);
      logger.info("Completed JvmInitializer#beforeProcessing for {}", initializer);
    }
  }
@Test
  public void runBeforeProcessing_runsInitializersWithOptions() {
    PipelineOptions options = TestPipeline.testingPipelineOptions();

    JvmInitializers.runBeforeProcessing(options);

    assertTrue(beforeProcessingRan);
    assertEquals(options, receivedOptions);
    expectedLogs.verifyInfo("Running JvmInitializer#beforeProcessing");
  }