Remove converted queue entries

diff --git a/update.php b/update.php
index cc4b0ea2cac6e47c66358dce7f08050463fa424c..40a3e8ff0d22ee39328b8eddcd39621144af1e00 100644 (file)
--- a/update.php
+++ b/update.php
@@ -371,6 +371,7 @@ function update_1309()
                $deliver_options = ['priority' => PRIORITY_MEDIUM, 'dont_fork' => true];
                Worker::add($deliver_options, 'Delivery', $cmd, $item['id'], $entry['cid']);
                Logger::info('Added delivery worker', ['command' => $cmd, 'item' => $item['id'], 'contact' => $entry['cid']]);
+               DBA::delete('queue', ['id' => $entry['id']]);
        }
        return Update::SUCCESS;
 }