https://codedestine.com/redis-jedis-pub-sub-java/
public static void main(String[] args) {
Jedis jedis = new Jedis();
JedisPubSub jedisPubSub = new JedisPubSub() {
@Override
public void onPMessage(String pattern, String channel, String message) {
System.out.println("Channel " +channel+ " has sent a message : " +message+ " on pattern " + pattern);
if(pattern.equals("C*")) {
/* Unsubscribe from pattern C* after first message is received. */
punsubscribe(pattern);
}
}
@Override
public void onPSubscribe(String pattern, int subscribedChannels) {
System.out.println("Client is Subscribed to pattern : "+ pattern);
System.out.println("Client is Subscribed to "+ subscribedChannels + " no. of patterns");
}
@Override
public void onPUnsubscribe(String pattern, int subscribedChannels) {
System.out.println("Client is Unsubscribed from pattern : "+ pattern);
System.out.println("Client is Subscribed to "+ subscribedChannels + " no. of patterns");
}
};
jedis.psubscribe(jedisPubSub, "model_*");
}