diff --git a/mbuni/extras/pgsql-queue/mms_pgsql_queue.c b/mbuni/extras/pgsql-queue/mms_pgsql_queue.c
index 9f3f889..0bcd7d1 100644
--- a/mbuni/extras/pgsql-queue/mms_pgsql_queue.c
+++ b/mbuni/extras/pgsql-queue/mms_pgsql_queue.c
@@ -900,11 +900,11 @@ static void pgq_queue_run(char *dir,
      gwlist_remove_producer(items_list);
 
      for (i=0;i<num_threads; i++) 
-	  gwthread_cancel(th_ids[i]);
-     
+	  gwthread_wakeup(th_ids[i]);
+#if 0     
      for (i=0;i<num_threads; i++) 
 	  gwthread_join(th_ids[i]);    
-
+#endif
      gwlist_destroy(items_list, NULL);
      gw_free(th_ids);