Node Server - RAPJS

app.js

io.sockets.on('connection', function(socket) {

    const redisQueue = redis.createClient(port, hostname);
    redisQueue.subscribe('reporting');

    socket.emit('connected', "connected to the server" );
    count++;
    socket.emit('real-action', getVisitEvent(count));

    socket.on('disconnect', function() {
        count--;
        socket.emit('real-action', getVisitEvent(count));
    });

    redisQueue.on("message", function(channel, message) {
        socket.emit('recv-action', message );
    });

    setInterval(function() {
        socket.emit('real-action', getVisitEvent(count));
    }, 1200);

});