hazza/Phraseanet
1
0
Fork 0
mirror of https://github.com/alchemy-fr/Phraseanet.git synced 2025-10-15 22:13:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

admin worker consumed Q filter (#4347)

Browse Source
This commit is contained in:
Aina Sitraka
2023-07-25 10:35:18 +03:00
committed by GitHub
parent 491071c190
commit 8422eb550f
11 changed files with 92 additions and 48 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
lib/Alchemy/Phrasea/WorkerManager/Controller/AdminConfigurationController.php
View File

@@ -264,6 +264,7 @@ class AdminConfigurationController extends Controller
{
$reload = ($request->query->get('reload') == 1);
$hideEmptyQ = $request->query->get('hide-empty-queue');
$consumedQ = $request->query->get('consumed-queue');
if ($hideEmptyQ === null || $hideEmptyQ == 1) {
$hideEmptyQ = true;
@@ -271,9 +272,15 @@ class AdminConfigurationController extends Controller
$hideEmptyQ = false;
}
if ($consumedQ === null || $consumedQ == 1) {
$consumedQ = true;
} else {
$consumedQ = false;
}
$this->getAMQPConnection()->getChannel();
$this->getAMQPConnection()->declareExchange();
$queuesStatus = $this->getAMQPConnection()->getQueuesStatus($hideEmptyQ);
$queuesStatus = $this->getAMQPConnection()->getQueuesStatus($hideEmptyQ, $consumedQ);
return $this->render('admin/worker-manager/worker_queue_monitor.html.twig', [
'queuesStatus' => $queuesStatus,