<dependencies>
<dependency>
<groupId>com.github.etaty</groupId>
<artifactId>scredis_2.13</artifactId>
<version>2.2.0</version>
</dependency>
</dependencies>
import scredis.Client;
public class RedisClientExample {
public static void main(String[] args) {
Client scredisClient = new Client("localhost", 6379);
}
}
scredisClient.set("key", "value");
String value = scredisClient.get("key");
import scredis.Subscriber;
import scredis.messages.PMessage;
public class MessageListenerExample implements PMessage => Unit {
public void onMessage(PMessage<String, String> message) {
System.out.println("Received message: " + message);
}
}
Subscriber subscriber = new Subscriber(new MessageListenerExample(), Seq("channel"));