code: @Override
      public void initModule() throws ModuleInitializationException {
          Map<String, String> parameters = getParameters();
          copyPropertiesOverParameters(parameters);
          serverInterface = new ServerWrapper(getServer());
          logger.info("Journaling parameters: " + parameters);
          parseParameters(parameters);
  
          if (inRecoveryMode) {
              worker =
                      new JournalConsumer(parameters, getRole(), serverInterface);
          } else {
              worker = new JournalCreator(parameters, getRole(), serverInterface);
          }
          logger.info("Journal worker module is: " + worker.toString());
      }
docs: Augment the parameters with values obtained from System Properties, and
  create the proper worker (JournalCreator or JournalConsumer) for the
  current mode.