public void onSuccess ( StreamState state ) { logger . info ( String . format ( "[repair #%s] streaming task succeed, returning response to %s" , desc . sessionId , request . initiator ) ) ; MessagingService . instance ( ) . sendOneWay ( new SyncComplete ( desc , request . src , request . dst , true ) . createMessage ( ) , request . initiator ) ; }
If we succeeded on both stream in and out reply back to the initiator .