pl.edu.agh.age.services.worker.internal

Class DefaultUnicastMessenger

java.lang.Object

pl.edu.agh.age.services.worker.internal.DefaultUnicastMessenger

All Implemented Interfaces:

UnicastMessenger, CommunicationFacility

@Named
public final class DefaultUnicastMessenger
extends java.lang.Object
implements UnicastMessenger, CommunicationFacility

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Set<WorkerAddress>	computeNeighbours Addresses of workers - collected by the messenger itself.
private java.util.Set<UnicastMessageListener<java.io.Serializable>>	listeners
private WorkerAddress	localWorkerAddress
private static org.slf4j.Logger	log
private TopologyService	topologyService Topology service - needed for obtaining the node-level neighbours.
private WorkerCommunication	workerCommunication

Constructor Summary

Constructors

Constructor and Description
DefaultUnicastMessenger(TopologyService topologyService, WorkerCommunication workerCommunication)

Method Summary

Modifier and Type	Method and Description
(package private) void	addNeighbour(WorkerAddress workerAddress)
WorkerAddress	address()
private void	broadcastMyAddress()
java.util.Set<WorkerAddress>	neighbours()
<T extends java.io.Serializable> boolean	onMessage(WorkerMessage<T> workerMessage) Handles a message.
<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 UnicastMessenger.address()).
<T extends java.io.Serializable> void	removeListener(UnicastMessageListener<T> listener) Removes the listener.
void	reset()
<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.
void	start()
java.util.Set<WorkerMessage.Type>	subscribedTypes() Returns a set of message types that this listener wants to subscribe to.
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

log

private static final org.slf4j.Logger log

listeners

private final java.util.Set<UnicastMessageListener<java.io.Serializable>> listeners

computeNeighbours

private final java.util.Set<WorkerAddress> computeNeighbours

Addresses of workers - collected by the messenger itself.

localWorkerAddress

private final WorkerAddress localWorkerAddress

topologyService

private final TopologyService topologyService

Topology service - needed for obtaining the node-level neighbours.

workerCommunication

private final WorkerCommunication workerCommunication

Constructor Detail

DefaultUnicastMessenger

@Inject
public DefaultUnicastMessenger(TopologyService topologyService,
                                       WorkerCommunication workerCommunication)

Method Detail

address

public WorkerAddress address()

Specified by:

address in interface UnicastMessenger

neighbours

public java.util.Set<WorkerAddress> neighbours()

Specified by:

neighbours in interface UnicastMessenger

send

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

Description copied from interface: UnicastMessenger

Sends the message to the specified worker.

Specified by:

send in interface UnicastMessenger

Type Parameters:

T - a type of the payload.

Parameters:

receiver - a recipient of the message.

message - a message to send.

send

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

Description copied from interface: UnicastMessenger

Sends the message to the specified workers.

Specified by:

send in interface UnicastMessenger

Type Parameters:

T - a type of the payload.

Parameters:

receivers - a set of recipients of the message.

message - a message to send.

registerListener

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

Description copied from interface: UnicastMessenger

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

Specified by:

registerListener in interface UnicastMessenger

Type Parameters:

T - a type of the payload.

Parameters:

listener - a listener to register.

removeListener

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

Description copied from interface: UnicastMessenger

Removes the listener.

Specified by:

removeListener in interface UnicastMessenger

Type Parameters:

T - a type of the payload.

Parameters:

listener - a listener to remove.

onMessage

public <T extends java.io.Serializable> boolean onMessage(WorkerMessage<T> workerMessage)

Description copied from interface: CommunicationFacility

Handles a message.

Only messages directed to this node will be passed with this method, so implementers do not need to check whether they are recipients.

Specified by:

onMessage in interface CommunicationFacility

Type Parameters:

T - a type of the payload.

Parameters:

workerMessage - a received message (for the current node).

Returns:

true if the message should be not processed anymore, false otherwise.

subscribedTypes

public java.util.Set<WorkerMessage.Type> subscribedTypes()

Description copied from interface: CommunicationFacility

Returns a set of message types that this listener wants to subscribe to.

Specified by:

subscribedTypes in interface CommunicationFacility

start

public void start()

Specified by:

start in interface CommunicationFacility

reset

public void reset()

Specified by:

reset in interface CommunicationFacility

broadcastMyAddress

private void broadcastMyAddress()

addNeighbour

void addNeighbour(WorkerAddress workerAddress)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object