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

Interface CommunicationFacility

All Known Implementing Classes:

ComputeTopologyProvider, DefaultBroadcastMessenger, DefaultQueryProcessor, DefaultUnicastMessenger

public interface CommunicationFacility

Method Summary

Modifier and Type	Method and Description
<T extends java.io.Serializable> boolean	onMessage(WorkerMessage<T> workerMessage) Handles a message.
void	reset()
void	start()
java.util.Set<WorkerMessage.Type>	subscribedTypes() Returns a set of message types that this listener wants to subscribe to.

Method Detail

onMessage

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

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.

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

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

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

start

void start()

reset

void reset()