org.apache.flink.runtime.registration

Interface RegistrationConnectionListener<T extends RegisteredRpcConnection<?,?,S>,S extends RegistrationResponse.Success>

public interface RegistrationConnectionListener<T extends RegisteredRpcConnection<?,?,S>,S 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(T connection, S success) This method is called by the RegisteredRpcConnection when the registration is success.

Method Detail

onRegistrationSuccess

void onRegistrationSuccess(T connection,
                           S success)

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

Parameters:

success - The concrete response information for successful registration.

connection - The instance which established the connection

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.