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

Class DefaultBroadcastMessenger

java.lang.Object

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

All Implemented Interfaces:

BroadcastMessenger, CommunicationFacility

@Named
 @ThreadSafe
public final class DefaultBroadcastMessenger
extends java.lang.Object
implements BroadcastMessenger, CommunicationFacility

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Set<BroadcastMessageListener<java.io.Serializable>>	listeners
private static org.slf4j.Logger	log
private TopologyService	topologyService
private WorkerCommunication	workerCommunication

Constructor Summary

Constructors

Constructor and Description
DefaultBroadcastMessenger(WorkerCommunication workerCommunication, TopologyService topologyService)

Method Summary

Modifier and Type	Method and Description
<T extends java.io.Serializable> boolean	onMessage(WorkerMessage<T> workerMessage) Handles a message.
<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.
void	reset()
void	send(java.io.Serializable message) Sends the message to all neighbouring workers.
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<BroadcastMessageListener<java.io.Serializable>> listeners

topologyService

private final TopologyService topologyService

workerCommunication

private final WorkerCommunication workerCommunication

Constructor Detail

DefaultBroadcastMessenger

@Inject
public DefaultBroadcastMessenger(WorkerCommunication workerCommunication,
                                         TopologyService topologyService)

Method Detail

send

public void send(java.io.Serializable message)

Description copied from interface: BroadcastMessenger

Sends the message to all neighbouring workers.

Specified by:

send in interface BroadcastMessenger

Parameters:

message - a message to send.

registerListener

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

Description copied from interface: BroadcastMessenger

Registers a listener that will receive all incoming messages.

Specified by:

registerListener in interface BroadcastMessenger

Type Parameters:

T - a type of the payload.

Parameters:

listener - a listener to register.

removeListener

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

Description copied from interface: BroadcastMessenger

Removes the listener.

Specified by:

removeListener in interface BroadcastMessenger

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

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object