rsocket-consul-java

A library for streaming healthy service instances in Consul to the RSocket Java load balancer.

Usage

import com.dwolla.rsocket.LoadBalancerBuilder;

// Create a LoadBalancedRSocketMono for your service
LoadbalanceRSocketClient rSocket = new LoadBalancerBuilder().build("CONSUL_SERVICE_NAME");

// Then use the resulting RSocket like you would a single instance
rSocket.fireAndForget(DefaultPayload.create("do something"));