Atomix 2.1.0 beta1 Usage

package com.example.atomix;

import io.atomix.cluster.Node;
import io.atomix.core.Atomix;
import io.atomix.messaging.Endpoint;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class Main {

    private static final Logger LOGGER = LoggerFactory.getLogger(Main.class);

    public static void main(String[] args) {
        new Main().run();
    }

    public void run() {
        Atomix.Builder builder = Atomix.builder();

        builder.withLocalNode(Node.builder("server1")
            .withType(Node.Type.DATA)
            .withEndpoint(Endpoint.from("localhost", 5000))
            .build());

        builder.withBootstrapNodes(
            Node.builder("server1")
                .withType(Node.Type.DATA)
                .withEndpoint(Endpoint.from("localhost", 5000))
                .build(),
            Node.builder("server2")
                .withType(Node.Type.DATA)
                .withEndpoint(Endpoint.from("localhost", 5001))
                .build(),
            Node.builder("server3")
                .withType(Node.Type.DATA)
                .withEndpoint(Endpoint.from("localhost", 5002))
                .build());

        Atomix atomix = builder.build();

        LOGGER.info("Starting Atomix");
        atomix.start().join();
        LOGGER.info("Started Atomix successfully");
    }

}