adunkman/index.html

## index.html
<!DOCTYPE html>
<html>
   <head>
      <script src="/socket.io/socket.io.js"></script>
      <script>
         (function () {

            var onMessage = function (data) {
               // Do something with the message data
            };

            var connectToServer = function () {
               var socket = io.connect('http://localhost:8080');
               socket.on('message-name', onMessage);
            };

            connectToServer();

         })();

      </script>
   </head>
   <body>
   </body>
</html>

## server.js
var amqp = require('amqp'),
    express = require('express'),
    app = express.createServer(),
    io = require('socket.io').listen(app),
    rabbitMq = amqp.createConnection({ host: 'rabbitmq-host.com' });

app.configure(function () {
   app.use(express.static(__dirname + '/public'));
   app.use(express.errorHandler({ dumpExceptions: true, showStack: true }));
});

rabbitMq.on('ready', function () {
   io.sockets.on('connection', function (socket) {
      var queue = rabbitMq.queue('my-queue');

      queue.bind('#'); // all messages

      queue.subscribe(function (message) {
         socket.emit('message-name', message);
      });
   });
});

app.listen(8080);
	<!DOCTYPE html>
	<html>
	<head>
	<script src="/socket.io/socket.io.js"></script>
	<script>
	(function () {

	var onMessage = function (data) {
	// Do something with the message data
	};

	var connectToServer = function () {
	var socket = io.connect('http://localhost:8080');
	socket.on('message-name', onMessage);
	};

	connectToServer();

	})();

	</script>
	</head>
	<body>
	</body>
	</html>
	var amqp = require('amqp'),
	express = require('express'),
	app = express.createServer(),
	io = require('socket.io').listen(app),
	rabbitMq = amqp.createConnection({ host: 'rabbitmq-host.com' });

	app.configure(function () {
	app.use(express.static(__dirname + '/public'));
	app.use(express.errorHandler({ dumpExceptions: true, showStack: true }));
	});

	rabbitMq.on('ready', function () {
	io.sockets.on('connection', function (socket) {
	var queue = rabbitMq.queue('my-queue');

	queue.bind('#'); // all messages

	queue.subscribe(function (message) {
	socket.emit('message-name', message);
	});
	});
	});

	app.listen(8080);