pl.edu.agh.age.examples

Class SimpleWithUnicastCommunication

java.lang.Object

pl.edu.agh.age.examples.SimpleWithUnicastCommunication

All Implemented Interfaces:

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

public final class SimpleWithUnicastCommunication
extends java.lang.Object
implements java.lang.Runnable, UnicastMessageListener<java.lang.String>

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

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

Sent messages can have any serializable payload.

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

See Also:

TopologyService

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
SimpleWithUnicastCommunication(UnicastMessenger messenger)

Method Summary

Modifier and Type	Method and Description
void	onUnicastMessage(@NonNull java.lang.String message, @NonNull WorkerAddress sender)
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 UnicastMessenger messenger

Constructor Detail

SimpleWithUnicastCommunication

@Inject
public SimpleWithUnicastCommunication(UnicastMessenger 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

onUnicastMessage

public void onUnicastMessage(@NonNull java.lang.String message,
                             @NonNull WorkerAddress sender)

Specified by:

onUnicastMessage in interface UnicastMessageListener<java.lang.String>