scalecube-cluster

scalecube-cluster copied to clipboard

Scalecube-cluster project hava README with examples:

// Start cluster node Alice as a seed node of the cluster, listen and print all incoming messages
Cluster alice = Cluster.joinAwait();
alice.listen().subscribe(msg -> System.out.println("Alice received: " + msg.data()));

// Join cluster node Bob to cluster with Alice, listen and print all incoming messages
Cluster bob = Cluster.joinAwait(alice.address());
bob.listen().subscribe(msg -> System.out.println("Bob received: " + msg.data()));

but now, interface Cluster doesn't have static method joinAwait(develop and 2.5.0 tag)