pl.edu.agh.age.compute.api

Interface BroadcastMessenger

All Known Implementing Classes:

DefaultBroadcastMessenger

@ThreadSafe
public interface BroadcastMessenger

Messenger for the broadcast (pub-sub type) 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
<T extends java.io.Serializable> void	registerListener(BroadcastMessageListener<T> listener) Registers a listener that will receive all incoming messages.
<T extends java.io.Serializable> void	removeListener(BroadcastMessageListener<T> listener) Removes the listener.
<T extends java.io.Serializable> void	send(T message) Sends the message to all neighbouring workers.

Method Detail

send

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

Sends the message to all neighbouring workers.

Type Parameters:

T - a type of the payload.

Parameters:

message - a message to send.

registerListener

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

Registers a listener that will receive all incoming messages.

Type Parameters:

T - a type of the payload.

Parameters:

listener - a listener to register.

removeListener

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

Removes the listener.

Type Parameters:

T - a type of the payload.

Parameters:

listener - a listener to remove.