--- node_modules/pg-table-observer/dist/PgTableObserver.js.orig	2019-01-05 14:11:33.303140087 -0800
+++ node_modules/pg-table-observer/dist/PgTableObserver.js	2019-01-05 14:19:24.817530060 -0800
@@ -373,7 +373,7 @@
                             trigger_name = channel + '_' + table;
                             _context4.prev = 2;
                             _context4.next = 5;
-                            return db.none('\n            CREATE TRIGGER $1~\n            AFTER INSERT OR UPDATE OR DELETE ON $2~\n            FOR EACH ROW EXECUTE PROCEDURE $3~()\n          ', [trigger_name, table, _this2.trigger_func]);
+                            return db.none('\n            BEGIN; DROP TRIGGER IF EXISTS "' + trigger_name + '" ON "' + table + '"; CREATE TRIGGER "' + trigger_name + '"\n            AFTER INSERT OR UPDATE OR DELETE ON "' + table + '"\n            FOR EACH ROW EXECUTE PROCEDURE "' + _this2.trigger_func + '"(); COMMIT;\n          ');
 
                           case 5:
                             _context4.next = 9;