/
mikopbx
/
ModuleZabbixAgent5
Обзор
Документация
Войти
/
mikopbx
/
ModuleZabbixAgent5
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
CI/CD
Аналитика
master
Lib/WorkerZabbixAgent5Main.php
56 строк
1 KB
apor
.
19 июл 2021, 10:59
19 июл 2021, 10:59
1404de1
Код
Авторство
О чём код?
<?php namespace Modules\ModuleZabbixAgent5\Lib; use MikoPBX\Core\System\BeanstalkClient; use MikoPBX\Core\System\Util; use Error; use MikoPBX\Core\Workers\WorkerBase; require_once 'Globals.php'; class WorkerZabbixAgent5Main extends WorkerBase { protected ZabbixAgent5Main $templateMain; /** * Worker start point * * @param $argv */ public function start($argv): void { $this->templateMain = new ZabbixAgent5Main(); $client = new BeanstalkClient(self::class); $client->subscribe($this->makePingTubeName(self::class), [$this, 'pingCallBack']); $client->subscribe(self::class, [$this, 'beanstalkCallback']); while (true) { $client->wait(); } } /** * Parser for received Beanstalk message * * @param BeanstalkClient $message */ public function beanstalkCallback($message): void { $receivedMessage = json_decode($message->getBody(), true); $this->templateMain->processBeanstalkMessage($receivedMessage); } } // Start worker process $workerClassname = WorkerZabbixAgent5Main::class; if (isset($argv) && count($argv) > 1) { cli_set_process_title($workerClassname); try { $worker = new $workerClassname(); $worker->start($argv); } catch (Error $e) { global $errorLogger; $errorLogger->captureException($e); Util::sysLogMsg("{$workerClassname}_EXCEPTION", $e->getMessage()); } }