a couple of things to make queue items work

darcs-hash:20080704052240-34904-c6458bbd6842cd8a86929bba60fb0d4408b56345.gz

diff --git a/lib/common.php b/lib/common.php
index 0b5b4ab5cc722b052fa1c4e946a6546bdbaa0157..d3d9fc87f1b0f353a4818ad57ed3b660ce2c8d13 100644 (file)
--- a/lib/common.php
+++ b/lib/common.php
@@ -97,5 +97,6 @@ require_once(INSTALLDIR.'/classes/Subscription.php');
 require_once(INSTALLDIR.'/classes/User.php');
 require_once(INSTALLDIR.'/classes/Confirm_address.php');
 require_once(INSTALLDIR.'/classes/Remember_me.php');
+require_once(INSTALLDIR.'/classes/Queue_item.php');
 
 require_once('markdown.php');

diff --git a/lib/util.php b/lib/util.php
index 03d549334a2a6db5ca0d675b3216d8972be5c62e..8e8860b417e5ec73e7522b96b52922570fd07d13 100644 (file)
--- a/lib/util.php
+++ b/lib/util.php
@@ -820,9 +820,11 @@ function common_broadcast_notice($notice, $remote=false) {
 
 function common_enqueue_notice($notice) {
        $qi = new Queue_item();
+        $qi->query('BEGIN');
        $qi->notice_id = $notice->id;
        $qi->created = DB_DataObject_Cast::dateTime();
        $result = $qi->insert();
+        $qi->query('COMMIT');
        return $result;
 }