@@ -448,7 +448,7 @@ private ServiceResponse save(Class c, ServiceRequest request, Database database)
 
 
           //Fire event
-            if (isNew) onCreate(obj); else onUpdate(obj);
+            if (isNew) onCreate(obj, request); else onUpdate(obj, request);
 
 
           //Return response
@@ -490,7 +490,7 @@ private ServiceResponse delete(Class c, ServiceRequest request, Database databas
             delete.invoke(obj);
 
           //Fire event
-            onDelete(obj);
+            onDelete(obj, request);
 
           //Return response
             return new ServiceResponse(200);
@@ -502,9 +502,9 @@ private ServiceResponse delete(Class c, ServiceRequest request, Database databas
     }
 
 
-    public void onCreate(Object obj){};
-    public void onUpdate(Object obj){};
-    public void onDelete(Object obj){};
+    public void onCreate(Object obj, ServiceRequest request){};
+    public void onUpdate(Object obj, ServiceRequest request){};
+    public void onDelete(Object obj, ServiceRequest request){};
 
 
   //**************************************************************************
 
@@ -84,7 +84,7 @@ public QueryService(Database database, javaxt.io.Directory jobDir, javaxt.io.Dir
       //Spawn threads used to execute queries
         int numThreads = 1; //TODO: Make configurable...
         for (int i=0; i<numThreads; i++){
-            new Thread(new QueryProcessor(database)).start();
+            new Thread(new QueryProcessor(database, this)).start();
         }
     }
 
@@ -126,6 +126,12 @@ else if (path.equals("tables")){
     }
 
 
+  //**************************************************************************
+  //** notify
+  //**************************************************************************
+    public void notify(QueryJob job){}
+
+
   //**************************************************************************
   //** query
   //**************************************************************************
@@ -573,6 +579,7 @@ private ServiceResponse cancel(ServiceRequest request, Database database) {
           //Update job status
             job.status = "canceled";
             job.updated = new javaxt.utils.Date();
+            notify(job);
 
 
           //Cancel the query in the database
@@ -742,6 +749,18 @@ public QueryJob(long userID, Select select, Long offset, Long limit, JSONObject
             }
         }
 
+        public String getID(){
+            return id;
+        }
+
+        public long getUserID(){
+            return userID;
+        }
+
+        public String getStatus(){
+            return status;
+        }
+
         public void addTempTable(CreateTable stmt){
             tempTable = stmt;
         }
@@ -865,9 +884,11 @@ public JSONObject toJson() {
    */
     private class QueryProcessor implements Runnable {
         private Database database;
+        private QueryService queryService;
 
-        public QueryProcessor(Database database){
+        public QueryProcessor(Database database, QueryService queryService){
             this.database = database;
+            this.queryService = queryService;
         }
 
         public void run() {
@@ -906,6 +927,7 @@ public void run() {
                             job.status = "running";
                             job.updated = new javaxt.utils.Date();
                             long startTime = System.currentTimeMillis();
+                            queryService.notify(job);
 
 
                           //Open database connection
@@ -977,6 +999,7 @@ public void run() {
                           //Update job status
                             job.status = "complete";
                             job.updated = new javaxt.utils.Date();
+                            queryService.notify(job);
                         }
                         catch(Exception e){
                             if (conn!=null) conn.close();
@@ -987,6 +1010,7 @@ public void run() {
                             else{
                                 job.status = "failed";
                                 job.updated = new javaxt.utils.Date();
+                                queryService.notify(job);
 
 
                                 java.io.PrintStream ps = null;