var pg = require('pg'),
    gearmanode = require('gearmanode'),
    gearmanClient,
    conString = 'tcp://username:password@localhost:5432/gonzalo',
    pgClient;

gearmanode.Client.logger.transports.console.level = 'error';

gearmanClient = gearmanode.client();

console.log('LISTEN myEvent');
pgClient = new pg.Client(conString);
pgClient.connect();
pgClient.query('LISTEN myEvent');
pgClient.on('notification', function (data) {
    console.log("33[34m" + new Date + '-33[0m payload', data.payload);
    gearmanClient.submitJob('sms.sender.one', data.payload);
});

$dbconn = pg_connect("host=".$DB_SERVER." port=".$DB_PORT." user=".$DB_USER." password=".$DB_PASSWORD." dbname=".$DB);

$dbconn->exec('LISTEN "myEvent"');

$inc=0;

while (1) {
  $result = "";

  $result = pg_get_notify($dbconn);

  if ($result) {
      // Here, instead of echoing out the result, I will be parsing it
      // and inserting values from the result into another table
      echo '33[34m' + date('DATE_RFC2822') + '-33[0m payload', $result)."nn";
      $inc++;
  }
}