docs: public void runBenchmark() throws Exception {
          printHeading("Publishing Train Activities");
  
          String trains[] = { "1", "2", "3", "4", "5", "6", "7", "8" };
          List<TrainActivityPublisher> trainPubs = new ArrayList<>();
          SwipeEntryActivityPublisher entry = new SwipeEntryActivityPublisher(config, producerConfig, config.count);
          entry.start();
          SwipeExitActivityPublisher exit = new SwipeExitActivityPublisher(config, producerConfig, config.count);
          exit.start();
          SwipeReplenishActivityPublisher replenish = new SwipeReplenishActivityPublisher(config, producerConfig, config.count/5);
          replenish.start();
          //Wait for a min to start trains.
          Thread.sleep(6000);
          System.out.println("Starting All Trains....");
          for (String train : trains) {
              TrainActivityPublisher redLine = new TrainActivityPublisher(train, config, producerConfig, Integer.MAX_VALUE);
              redLine.start();
              trainPubs.add(redLine);
          }
          System.out.println("All Trains Started....");
          entry.join();
          exit.close = true;
          exit.join();
          replenish.close = true;
          replenish.join();
      }