Skip to content

Instantly share code, notes, and snippets.

@smaldini
Last active November 11, 2015 00:28
Show Gist options
  • Save smaldini/c9cfc68055bdce3890e8 to your computer and use it in GitHub Desktop.
Save smaldini/c9cfc68055bdce3890e8 to your computer and use it in GitHub Desktop.
TBD
// AeronProcessor as a server
AeronProcessor server = AeronProcessor.builder()
.senderChannel("udp://localhost:12000")
.receiverChannel("udp://localhost:12001")
.senderOnly(true)
.create();
//
IO.readFile("~/test.txt")
.subscribe(server);
// AeronProcessor as a client
AeronProcessor client = AeronProcessor.builder()
.senderChannel("udp://localhost:12000")
.receiverChannel("udp://localhost:12001")
.receiverOnly(true)
.create();
client.subscribe(Subscribers.unbounded(Buffer::asString()));
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment