pl.edu.agh.age.compute.api

Interface UnicastMessenger

All Known Implementing Classes:

DefaultUnicastMessenger

@ThreadSafe
public interface UnicastMessenger

Messenger for the unicast communication between workers.

Implementations need to be thread-safe, as they are presented to possibly multi-threaded compute code.

Method Summary

Modifier and Type	Method and Description
WorkerAddress	address()
java.util.Set<WorkerAddress>	neighbours()
<T extends java.io.Serializable> void	registerListener(UnicastMessageListener<T> listener) Registers a listener that will receive all incoming messages target for this address (obtained via address()).
<T extends java.io.Serializable> void	removeListener(UnicastMessageListener<T> listener) Removes the listener.
<T extends java.io.Serializable> void	send(java.util.Set<WorkerAddress> receivers, T message) Sends the message to the specified workers.
<T extends java.io.Serializable> void	send(WorkerAddress receiver, T message) Sends the message to the specified worker.

Method Detail

address

WorkerAddress address()

neighbours

java.util.Set<WorkerAddress> neighbours()

send

<T extends java.io.Serializable> void send(WorkerAddress receiver,
                                           T message)

Sends the message to the specified worker.

Type Parameters:

T - a type of the payload.

Parameters:

receiver - a recipient of the message.

message - a message to send.

send

<T extends java.io.Serializable> void send(java.util.Set<WorkerAddress> receivers,
                                           T message)

Sends the message to the specified workers.

Type Parameters:

T - a type of the payload.

Parameters:

receivers - a set of recipients of the message.

message - a message to send.

registerListener

<T extends java.io.Serializable> void registerListener(UnicastMessageListener<T> listener)

Registers a listener that will receive all incoming messages target for this address (obtained via address()).

Type Parameters:

T - a type of the payload.

Parameters:

listener - a listener to register.

removeListener

<T extends java.io.Serializable> void removeListener(UnicastMessageListener<T> listener)

Removes the listener.

Type Parameters:

T - a type of the payload.

Parameters:

listener - a listener to remove.