import io.lettuce.core.RedisClient;
import io.lettuce.core.api.StatefulRedisConnection;
import io.lettuce.core.api.reactive.RedisReactiveCommands;
public class LettuceExample {
public static void main(String[] args) {
RedisClient client = RedisClient.create("redis://localhost");
StatefulRedisConnection<String, String> connection = client.connect();
RedisReactiveCommands<String, String> commands = connection.reactive();
commands.set("key", "value")
.then(commands.get("key"))
.subscribe(System.out::println);
connection.close();
client.shutdown();
}
}
