server.js

var app = require('./app');
var mqtt = require('mqtt');

var server = app.listen(3000, function() {
			console.log('BML now listening on port ' + server.address().port);
		});
var io = require('socket.io')(server);
var client = mqtt.connect('tcp://54.165.237.24:1883');

require('tls').SLAB_BUFFER_SIZE = 100 * 1024 //100Kb

io.on('connection', function(socket){
	 socket.on('berry', function(msg){
	   //console.log('message: ' + msg);
	   io.sockets.emit('newdata', msg);
	 });
	 socket.on('ecgIn', function(msg){
	   //console.log('message: ' + msg);
	   io.sockets.emit('ecgOut', msg);
	 });
	 socket.on('strainIn', function(msg){
	   //console.log('message: ' + msg);
	   io.sockets.emit('strainOut', msg);
	 });
	 socket.on('crateSum', function(msg){
	   //console.log('message: ' + msg);
	   io.sockets.emit('crateSumOut', msg);
	 });
	});

client.on('connect', function () {
  client.subscribe('/sensor/json/');
  client.publish('/sensor/status/', 'Start');
});

client.on('message', function (topic, message) {
  //console.log("Message:"+message);
  message = message.toString();
  io.sockets.emit('mqttOut',message.trim());
});

client.addListener('/sensor/json/', function(topic, payload){
  //console.log(topic+'='+payload);
});

setInterval(function() {
			io.sockets.emit('time', new Date());
		}, 10);