var mqtt = require('mqtt');

console.log('Time\tIncoming\tInternal\t\tOccupied');

var start = null;
var now = null;
var client = mqtt.createClient(1883, 'test.mosquitto.org');

client.on('connect', function() {
  this.subscribe('#');
  this.stream.on('data', function(data) {
    var length = client.conn.buffer ? client.conn.buffer.length : 0
      , written = client.conn.buffer ? client.conn.buffer.written : 0
      , read = client.conn.buffer ? client.conn.buffer.read : 0;
    if(!start) start = (new Date()).valueOf();
    now = (new Date()).valueOf();

    console.log(
      '%d\t%d\t\t%d\t\t%d',
      now - start,
      data.length, 
      length,
      written - read
    );
  });
});