Uses of Interface
org.apache.reef.wake.remote.RemoteMessage

Packages that use RemoteMessage

Package	Description
org.apache.reef.runtime.common.driver.evaluator	Driver-Side representations of Evaluators.
org.apache.reef.runtime.common.utils
org.apache.reef.wake.remote
org.apache.reef.wake.remote.impl

Uses of RemoteMessage in org.apache.reef.runtime.common.driver.evaluator

Methods in org.apache.reef.runtime.common.driver.evaluator with parameters of type RemoteMessage

Modifier and Type	Method and Description
void	EvaluatorManager.onEvaluatorHeartbeatMessage(RemoteMessage<EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto> evaluatorHeartbeatProtoRemoteMessage)
void	EvaluatorHeartbeatHandler.onNext(RemoteMessage<EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto> evaluatorHeartbeatMessage)
void	EvaluatorResourceManagerErrorHandler.onNext(RemoteMessage<ReefServiceProtos.RuntimeErrorProto> runtimeErrorProtoRemoteMessage)

Uses of RemoteMessage in org.apache.reef.runtime.common.utils

Method parameters in org.apache.reef.runtime.common.utils with type arguments of type RemoteMessage

Modifier and Type	Method and Description
<T,U extends T> AutoCloseable	RemoteManager.registerHandler(Class<U> messageType, EventHandler<RemoteMessage<T>> theHandler)

Uses of RemoteMessage in org.apache.reef.wake.remote

Method parameters in org.apache.reef.wake.remote with type arguments of type RemoteMessage

Modifier and Type	Method and Description
<T,U extends T> AutoCloseable	RemoteManager.registerHandler(Class<U> messageType, EventHandler<RemoteMessage<T>> theHandler) Registers the given EventHandler to be called for the given message type from any source.

Uses of RemoteMessage in org.apache.reef.wake.remote.impl

Method parameters in org.apache.reef.wake.remote.impl with type arguments of type RemoteMessage

Modifier and Type	Method and Description
<T,U extends T> AutoCloseable	DefaultRemoteManagerImplementation.registerHandler(Class<U> messageType, EventHandler<RemoteMessage<T>> theHandler) Registers an event handler for a message type and returns a subscription