Aeron gist

gistfile1.txt

// AeronProcessor as a server
        AeronProcessor processor = AeronProcessor.builder()
                .name("server")
                .senderChannel("udp://localhost:12000")
                .receiverChannel("udp://localhost:12001")
                .senderOnly(true)
                .create();
        
        Streams.range(1, 1000)
                .map(i -> Buffer.wrap("" + i))
                .subscribe(processor);
                

// AeronProcessor as a client
        AeronProcessor processor = AeronProcessor.builder()
                .name("client")
                .senderChannel("udp://localhost:12000")
                .receiverChannel("udp://localhost:12001")
                .receiverOnly(true)
                .create();

        processor.subscribe(
                Subscribers.unbounded((next, sub) -> System.out.println(next)));