Code Coverage |
||||||||||
Classes and Traits |
Functions and Methods |
Lines |
||||||||
| Total | |
100.00% |
1 / 1 |
|
100.00% |
1 / 1 |
CRAP | |
100.00% |
2 / 2 |
| Queue | |
100.00% |
1 / 1 |
|
100.00% |
1 / 1 |
3 | |
100.00% |
2 / 2 |
| setMessageBus | |
100.00% |
1 / 1 |
1 | |
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 | |
| 31 | namespace App\Core\Queue; |
| 32 | |
| 33 | use Symfony\Component\Messenger\MessageBusInterface; |
| 34 | |
| 35 | abstract 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 | } |