protected void sendInstallRequest ( Connection connection , MemberState member , InstallRequest request ) { logger . trace ( "{} - Sending {} to {}" , context . getCluster ( ) . member ( ) . address ( ) , request , member . getMember ( ) . serverAddress ( ) ) ; connection . < InstallRequest , InstallResponse > sendAndReceive ( request ) . whenComplete ( ( response , error ) -> { context . checkThread ( ) ; // Complete the install to the member. member . completeInstall ( ) ; if ( open ) { if ( error == null ) { logger . trace ( "{} - Received {} from {}" , context . getCluster ( ) . member ( ) . address ( ) , response , member . getMember ( ) . serverAddress ( ) ) ; handleInstallResponse ( member , request , response ) ; } else { logger . warn ( "{} - Failed to install {}" , context . getCluster ( ) . member ( ) . address ( ) , member . getMember ( ) . serverAddress ( ) ) ; // Trigger reactions to the install response failure. handleInstallResponseFailure ( member , request , error ) ; } } } ) ; }
Sends a snapshot message .