34 lines
1.0 KiB
JavaScript
34 lines
1.0 KiB
JavaScript
var redis = require("redis"),
|
|
client1 = redis.createClient(),
|
|
client2 = redis.createClient(),
|
|
client3 = redis.createClient(),
|
|
client4 = redis.createClient(),
|
|
msg_count = 0;
|
|
|
|
redis.debug_mode = false;
|
|
|
|
client1.on("psubscribe", function (pattern, count) {
|
|
console.log("client1 psubscribed to " + pattern + ", " + count + " total subscriptions");
|
|
client2.publish("channeltwo", "Me!");
|
|
client3.publish("channelthree", "Me too!");
|
|
client4.publish("channelfour", "And me too!");
|
|
});
|
|
|
|
client1.on("punsubscribe", function (pattern, count) {
|
|
console.log("client1 punsubscribed from " + pattern + ", " + count + " total subscriptions");
|
|
client4.end();
|
|
client3.end();
|
|
client2.end();
|
|
client1.end();
|
|
});
|
|
|
|
client1.on("pmessage", function (pattern, channel, message) {
|
|
console.log("("+ pattern +")" + " client1 received message on " + channel + ": " + message);
|
|
msg_count += 1;
|
|
if (msg_count === 3) {
|
|
client1.punsubscribe();
|
|
}
|
|
});
|
|
|
|
client1.psubscribe("channel*");
|