pl.edu.agh.age.examples

Class SimpleWithBroadcastCommunication

java.lang.Object

pl.edu.agh.age.examples.SimpleWithBroadcastCommunication

All Implemented Interfaces:

java.lang.Runnable, BroadcastMessageListener<java.lang.String>

public final class SimpleWithBroadcastCommunication
extends java.lang.Object
implements java.lang.Runnable, BroadcastMessageListener<java.lang.String>

This example shows how the compute level can communicate between nodes using broadcast messages.

Broadcast messaging is performed in regards of the topology defined in the platform level and the messages are sent only to neighbours of the current node.

Sent messages can have any serializable payload.

To receive messages, the runnable must register a BroadcastMessageListener using BroadcastMessenger.registerListener(pl.edu.agh.age.compute.api.BroadcastMessageListener<T>).

See Also:

TopologyService

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	logger
private BroadcastMessenger	messenger

Constructor Summary

Constructors

Constructor and Description
SimpleWithBroadcastCommunication(BroadcastMessenger messenger)

Method Summary

Modifier and Type	Method and Description
void	onBroadcastMessage(@NonNull java.lang.String message)
void	run()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final org.slf4j.Logger logger

messenger

private final BroadcastMessenger messenger

Constructor Detail

SimpleWithBroadcastCommunication

@Inject
public SimpleWithBroadcastCommunication(BroadcastMessenger messenger)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

onBroadcastMessage

public void onBroadcastMessage(@NonNull java.lang.String message)

Specified by:

onBroadcastMessage in interface BroadcastMessageListener<java.lang.String>