From b61d535f81af4c2ec2bcabd4378f1a8bfa3cd446 Mon Sep 17 00:00:00 2001 From: Friendika Date: Sun, 28 Aug 2011 22:59:49 -0700 Subject: remove item from queue --- include/delivery.php | 13 +++++++++++++ 1 file changed, 13 insertions(+) (limited to 'include/delivery.php') diff --git a/include/delivery.php b/include/delivery.php index 1f5883c26..e32a9346c 100644 --- a/include/delivery.php +++ b/include/delivery.php @@ -37,6 +37,19 @@ function delivery_run($argv, $argc){ $item_id = intval($argv[2]); $contact_id = intval($argv[3]); + // Some other process may have delivered this item already. + + $r = q("select * from deliverq where cmd = '%s' and item = %d and contact = %d limit 1", + dbesc($cmd), + dbesc($item_id), + dbesc($contact_id) + ); + if(! count($r)) { + return; + } + + // It's ours to deliver. Remove it from the queue. + q("delete from deliverq where cmd = '%s' and item = %d and contact = %d limit 1", dbesc($cmd), dbesc($item_id), -- cgit v1.2.3