var pg  = require('pg');
var bus = require('pg-bus');
 
var url = 'postgres://localhost/postgres';
 
pg.connection(url, function(err, db) {
  if (err) throw err;
 
  var messages = bus(db, 'messages');
 
  messages.listen('message', function(data) {
    console.log(data);
    // { foo: 'bar' }
  });
 
  messages.notify('message', { foo: 'bar' });
});