private void sync ( ImmutableMember member ) { LOGGER . trace ( "{} - Synchronizing membership with {}" , localMember . id ( ) , member ) ; bootstrapService . getMessagingService ( ) . sendAndReceive ( member . address ( ) , MEMBERSHIP_SYNC , SERIALIZER . encode ( localMember . copy ( ) ) , false , config . getProbeTimeout ( ) ) . whenCompleteAsync ( ( response , error ) -> { if ( error == null ) { Collection < ImmutableMember > members = SERIALIZER . decode ( response ) ; members . forEach ( this :: updateState ) ; } else { LOGGER . debug ( "{} - Failed to synchronize membership with {}" , localMember . id ( ) , member ) ; } } , swimScheduler ) ; }
Synchronizes the node state with the given peer .