socket.io + redis notifications server

server.js

var app = require('express')();
var server = require('http').Server(app);
var io = require('socket.io')(server);
var redis = require('redis').createClient({host: 'localhost'});
var port = process.env.PORT || 8890;

server.listen(port);

io.on('connection', function (socket) {
  socket.on('subscribe', function(data) {
    console.log('Joining room', data.room);
    socket.join(data.room);
    redis.subscribe(data.room);
  })

  socket.on('disconnect', function() {
    delete io.sockets[socket.id];
  });
});

redis.on('message', function(room, message) {
  console.log('Redis message: ' + message + '. In room: ' + room);
  io.in(room).emit('message', message);
});