nodejs - redis

var express = require('express');
var app = express();
var server = require('http').createServer(app);
var io = require('socket.io')(server);
var port = process.env.PORT || 8080;
var serverName = process.env.NAME || 'Unknown';
var redis = require('redis');
client = redis.createClient();
server.listen(8080);

// Redis İstekleri Al

io.on('connection', function(socket) {
	    io.emit('istekler', 'baglandiniz');

});


redisbaglan = redis.createClient();
redisbaglan.subscribe("istekler");
redisbaglan.on("message", function(channel, message) {

	var user = JSON.parse(message);
	console.log(user);
    io.emit(user.id, user.mesaj);
});