🌠 NATS Messenger (Work In Progress)

Extends pub/sub from NATS.io with lettuce-like (redis library) codecs and abstraction capabilities.

---

🌠 NATS Messenger :: Usage

Creating new client and connection:

final Options options = Options.builder()
        .server("nats://demo.nats.io:4222")
        .build();
final NatsClient natsClient = NatsMessenger.create(options);
final NatsConnection<String> natsConnection = natsClient.createConnection(new NatsStringCodec());

Subscribing to a channel and publishing messages:

natsConnection.subscribe("test-channel", new NatsTestListener());
/* Or */
natsConnection.subscribe("test-channel", value -> System.out.println(value));
natsConnection.publish("test-channel", "Test message!");
natsConection.publish("test-channel", "Test message with callback!", packet 
        -> System.out.println(packet));

natsConnection.flush(Duration.ZERO);

Example message listener:

class NatsMessageListener implements NatsHandler<String> {

    @Override
    public void onMessageReceive(String value) {
        System.out.println(value);
    }

}