@ Override public CompletableFuture < Void > add ( Operation operation , Duration timeout ) { ensureRunning ( ) ; return this . operationProcessor . process ( operation ) ; }
region OperationLog Implementation