@ 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 ( ) ; }
Initializes stream writers for commit and abort streams . This method should be called immediately after creating StreamTransactionMetadataTasks object .