org.apache.flink.runtime.registration

Interface RegistrationConnectionListener<Success extends RegistrationResponse.Success>

public interface RegistrationConnectionListener<Success extends RegistrationResponse.Success>

Classes which want to be notified about the registration result by the RegisteredRpcConnection have to implement this interface.

Method Summary

Modifier and Type	Method and Description
void	onRegistrationFailure(Throwable failure) This method is called by the RegisteredRpcConnection when the registration fails.
void	onRegistrationSuccess(Success success) This method is called by the RegisteredRpcConnection when the registration is success.

Method Detail

onRegistrationSuccess

void onRegistrationSuccess(Success success)

This method is called by the RegisteredRpcConnection when the registration is success.

Parameters:

success - The concrete response information for successful registration.

onRegistrationFailure

void onRegistrationFailure(Throwable failure)

This method is called by the RegisteredRpcConnection when the registration fails.

Parameters:

failure - The exception which causes the registration failure.