Skip to content

Instantly share code, notes, and snippets.

@aindong
Created June 17, 2015 06:34
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save aindong/d0d38ed4921f1069d2dd to your computer and use it in GitHub Desktop.
Save aindong/d0d38ed4921f1069d2dd to your computer and use it in GitHub Desktop.
var app = require('express')();
var server = require('http').Server(app);
var io = require('socket.io')(server);
var redis = require('redis');
server.listen(8890);
console.log('Socket server is now running on port: 8890');
io.on('connection', function (socket) {
console.log("new client connected");
var redisClient = redis.createClient();
redisClient.subscribe('patient-waiting');
redisClient.subscribe('patient-check-in');
redisClient.on("message", function(channel, message) {
console.log("New message in queue "+ message + "channel");
socket.emit(channel, message);
});
socket.on('disconnect', function() {
redisClient.quit();
});
});
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment