diff options
Diffstat (limited to 'include/queue.php')
| -rw-r--r-- | include/queue.php | 16 |
1 files changed, 5 insertions, 11 deletions
diff --git a/include/queue.php b/include/queue.php index 71ac50c83..5c3376661 100644 --- a/include/queue.php +++ b/include/queue.php @@ -114,20 +114,17 @@ function queue_run($argv, $argc){ dbesc(datetime_convert()), dbesc($rr['outq_hash']) ); - $y = q("delete from outq where outq_hash = '%s'", - dbesc($rr['outq_hash']) - ); + remove_queue_item($rr['outq_hash']); } else { logger('queue: queue post returned ' . $result['return_code'] . ' from ' . $rr['outq_posturl'],LOGGER_DEBUG); - $y = q("update outq set outq_updated = '%s', outq_priority = outq_priority + 10 where outq_hash = '%s'", - dbesc(datetime_convert()), - dbesc($rr['outq_hash']) - ); + update_queue_item($rr['outq_hash'],10); $deadguys[] = $rr['outq_posturl']; } continue; } + + $result = zot_zot($rr['outq_posturl'],$rr['outq_notify']); if($result['success']) { logger('queue: deliver zot success to ' . $rr['outq_posturl'], LOGGER_DEBUG); @@ -136,10 +133,7 @@ function queue_run($argv, $argc){ else { $deadguys[] = $rr['outq_posturl']; logger('queue: deliver zot returned ' . $result['return_code'] . ' from ' . $rr['outq_posturl'],LOGGER_DEBUG); - $y = q("update outq set outq_updated = '%s', outq_priority = outq_priority + 10 where outq_hash = '%s'", - dbesc(datetime_convert()), - dbesc($rr['outq_hash']) - ); + update_queue_item($rr['outq_hash'],10); } } } |