server.js

var io = require('socket.io').listen(9000, {log: false});

var redis = require("redis").createClient();

redis.subscribe('chat');
redis.subscribe('notifications');

var chat = io.of('/chat').
    on('connection', function (socket) {
    socket.on('register room', function (room) {
        socket.set('room', room);
    });
    redis.on('message', function (channel, message) {
        var messageObject = JSON.parse(message);
        if (channel === 'chat') {
            socket.get('room', function (err, room) {
                if (err === null && room !== null) {
                    if (messageObject.room.id === room.id) {
                        socket.emit('message', message);
                    }
                }
            });
        }
    });
});

var notifications = io.of('/notifications').
    on('connection', function (socket) {
    console.log(socket.id);
    socket.on('register user', function (user) {
        socket.set('user', user);
    });
    redis.on('message', function (channel, message) {
        var messageObject = JSON.parse(message);
        if (channel === 'notifications') {
            socket.get('user', function (err, user) {
                if (err === null && user !== null) {
                    if (user.id.toString() === messageObject.recipient.id.toString()) {
                        socket.emit('notification', message);
                    }
                }
            });
        }
    });
});