Remove converted queue entries
This commit is contained in:
parent
911ad99e61
commit
b30d01bea0
1 changed files with 1 additions and 0 deletions
|
@ -371,6 +371,7 @@ function update_1309()
|
||||||
$deliver_options = ['priority' => PRIORITY_MEDIUM, 'dont_fork' => true];
|
$deliver_options = ['priority' => PRIORITY_MEDIUM, 'dont_fork' => true];
|
||||||
Worker::add($deliver_options, 'Delivery', $cmd, $item['id'], $entry['cid']);
|
Worker::add($deliver_options, 'Delivery', $cmd, $item['id'], $entry['cid']);
|
||||||
Logger::info('Added delivery worker', ['command' => $cmd, 'item' => $item['id'], 'contact' => $entry['cid']]);
|
Logger::info('Added delivery worker', ['command' => $cmd, 'item' => $item['id'], 'contact' => $entry['cid']]);
|
||||||
|
DBA::delete('queue', ['id' => $entry['id']]);
|
||||||
}
|
}
|
||||||
return Update::SUCCESS;
|
return Update::SUCCESS;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue