layers {
layer1 {
nodes {
node1 {
host = "localhost"
port = 8080
}
node2 {
host = "example.com"
port = 8888
}
}
}
}
./startup.sh
import org.amdatu.tutorial.topology.api.Topology;
public class MessagingExample {
private Topology topology;
public MessagingExample(Topology topology) {
this.topology = topology;
}
public void sendMessage(String node, String message) {
topology.sendMessage(node, message);
}
public void receiveMessage(String message) {
System.out.println("Received message: " + message);
}
}
