diff --git a/index.js b/index.js
index 41023ed..6ec39fe 100644
--- a/index.js
+++ b/index.js
@@ -128,10 +128,10 @@ LivePg.prototype._initListener = function() {
                 && payload.table in queryBuffer.triggers
                 && (payload.op === 'UPDATE'
                   // Rows changed in an UPDATE operation must check old and new
-                  ? queryBuffer.triggers[payload.table](payload.new_data[0])
-                    || queryBuffer.triggers[payload.table](payload.old_data[0])
+                  ? queryBuffer.triggers[payload.table](payload.new_data[0], 'UPDATE')
+                    || queryBuffer.triggers[payload.table](payload.old_data[0], 'UPDATE_OLD')
                   // Rows changed in INSERT/DELETE operations only check once
-                  : queryBuffer.triggers[payload.table](payload.data[0])))
+                  : queryBuffer.triggers[payload.table](payload.data[0], payload.op)))
               || (queryBuffer.triggers
                 // No manual trigger for this table, always refresh
                 && !(payload.table in  queryBuffer.triggers))