heatmap_server.js

var express = require('express');
var app = express();
var server = require('http').createServer(app);
var io = require('socket.io').listen(server);
var amqp = require('amqp');
var amqpc = amqp.createConnection({ host: 'somehost', login: 'guest', password: 'guest', vhost: '/' });

process.on('exit', function() {
    amqpc.close();
});

io.set('log level', 1);
app.use(express.static(__dirname + '/public'));
app.set('views', __dirname + '/views');
app.set('view engine', 'twig');
app.set('twig options', {strict_variables: false});

app.get('/', function (req, res){
    res.render('index', {});
});

amqpc.on('ready', function () {
    amqpc.queue('heatmap', {passive: true}, function(q){
        q.subscribe(function (message) {
            if (message && message.data)
                io.sockets.emit('heatmap', JSON.parse(message.data.toString()));
        });
    });
});
server.listen(3000);