edu.snu.coral.runtime.common.message

Interface MessageSender<T>

Type Parameters:

T - message type

All Known Implementing Classes:

LocalMessageSender

public interface MessageSender<T>

This class sends messages to MessageListener with some defined semantics.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the connection.
<U> CompletableFuture<U>	request(T message) Send a message to corresponding MessageListener.onMessageWithContext(T, edu.snu.coral.runtime.common.message.MessageContext) and return a reply message.
void	send(T message) Send a message to corresponding MessageListener.onMessage(T).

Method Detail

send

void send(T message)

Send a message to corresponding MessageListener.onMessage(T). It does not guarantee whether the message is sent successfully or not.

Parameters:

message - a message

request

<U> CompletableFuture<U> request(T message)

Send a message to corresponding MessageListener.onMessageWithContext(T, edu.snu.coral.runtime.common.message.MessageContext) and return a reply message. If there was an exception, the returned future would be failed.

Type Parameters:

U - reply message type.

Parameters:

message - a message

Returns:

a future

close

void close()
    throws Exception

Closes the connection.

Throws:

Exception - while closing.