Code Coverage
 
Classes and Traits
Functions and Methods
Lines
Total
100.00% covered (success)
100.00%
1 / 1
100.00% covered (success)
100.00%
1 / 1
CRAP
100.00% covered (success)
100.00%
2 / 2
Queue
100.00% covered (success)
100.00%
1 / 1
100.00% covered (success)
100.00%
1 / 1
3
100.00% covered (success)
100.00%
2 / 2
 setMessageBus
100.00% covered (success)
100.00%
1 / 1
1
100.00% covered (success)
100.00%
2 / 2
 enqueue
n/a
0 / 0
2
n/a
0 / 0
1<?php
2
3// {{{ License
4// This file is part of GNU social - https://www.gnu.org/software/social
5//
6// GNU social is free software: you can redistribute it and/or modify
7// it under the terms of the GNU Affero General Public License as published by
8// the Free Software Foundation, either version 3 of the License, or
9// (at your option) any later version.
10//
11// GNU social is distributed in the hope that it will be useful,
12// but WITHOUT ANY WARRANTY; without even the implied warranty of
13// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14// GNU Affero General Public License for more details.
15//
16// You should have received a copy of the GNU Affero General Public License
17// along with GNU social.  If not, see <http://www.gnu.org/licenses/>.
18// }}}
19
20/**
21 * Queue wrapper
22 *
23 * @package  GNUsocial
24 * @category Wrapper
25 *
26 * @author    Hugo Sales <hugo@hsal.es>
27 * @copyright 2020-2021 Free Software Foundation, Inc http://www.fsf.org
28 * @license   https://www.gnu.org/licenses/agpl.html GNU AGPL v3 or later
29 */
30
31namespace App\Core\Queue;
32
33use Symfony\Component\Messenger\MessageBusInterface;
34
35abstract class Queue
36{
37    private static ?MessageBusInterface $message_bus;
38
39    public static function setMessageBus($mb): void
40    {
41        self::$message_bus = $mb;
42    }
43
44    /**
45     * Enqueue a $message in a configured transport, to be handled by the $queue handler
46     *
47     * @param mixed  $message
48     * @param string $queue
49     * @param bool   $high
50     * @param array  $stamps
51     * @codeCoverageIgnore
52     */
53    public static function enqueue($message, string $queue, bool $high = false, array $stamps = [])
54    {
55        if ($high) {
56            self::$message_bus->dispatch(new MessageHigh($message, $queue), $stamps);
57        } else {
58            self::$message_bus->dispatch(new MessageLow($message, $queue), $stamps);
59        }
60    }
61}