code: @Synchronized
      public void initializeStreamWriters(final EventStreamClientFactory clientFactory,
                                          final ControllerEventProcessorConfig config) {
          if (!commitWriterFuture.isDone()) {
              commitWriterFuture.complete(clientFactory.createEventWriter(
                      config.getCommitStreamName(),
                      ControllerEventProcessors.COMMIT_EVENT_SERIALIZER,
                      EventWriterConfig.builder().build()));
          }
          if (!abortWriterFuture.isDone()) {
              abortWriterFuture.complete(clientFactory.createEventWriter(
                      config.getAbortStreamName(),
                      ControllerEventProcessors.ABORT_EVENT_SERIALIZER,
                      EventWriterConfig.builder().build()));
          }
          this.setReady();
      }
docs: Initializes stream writers for commit and abort streams.
  This method should be called immediately after creating StreamTransactionMetadataTasks object.
  
  @param clientFactory Client factory reference.
  @param config Controller event processor configuration.