Package org.apache.flink.runtime.registration

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

public interface RegistrationConnectionListener<T extends RegisteredRpcConnection<?,?,S,?>,S extends RegistrationResponse.Success,R extends RegistrationResponse.Rejection>

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

Method Summary

Modifier and Type	Method	Description
void	onRegistrationFailure(Throwable failure)	This method is called by the RegisteredRpcConnection when the registration fails.
void	onRegistrationRejection(String targetAddress, R rejection)	This method is called by the RegisteredRpcConnection when the registration is rejected.
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.

onRegistrationRejection

void onRegistrationRejection(String targetAddress,
                             R rejection)

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

Parameters:

targetAddress - targetAddress from which the registration was rejected.

rejection - rejection containing more information.