Bitrix-D7
23.9
Загрузка...
Поиск...
Не найдено
pushdelayedconnectionagent.php
1
<?php
2
3
namespace
Bitrix\Calendar\Core\Queue\Agent
;
4
5
use
Bitrix\Calendar\Core\Queue\Consumer
;
6
use
Bitrix\Calendar\Core\Queue\Interfaces
;
7
use
Bitrix\Calendar\Core\Queue\Processor
;
8
use
Bitrix\Calendar\Core\Queue\Queue\QueueFactory
;
9
use
Bitrix\Calendar\Core\Queue\Queue\QueueRegistry
;
10
11
class
PushDelayedConnectionAgent
extends
BaseAgent
12
{
13
protected
function
getConsumer
(): Interfaces\
Consumer
14
{
15
$queue = (
new
QueueFactory
())->getById(QueueRegistry::QUEUE_LIST[
'DelayedSyncConnection'
]);
16
17
return
new
Consumer\GroupHash
($queue);
18
}
19
20
protected
function
getProcessor
(): Interfaces\
Processor
21
{
22
return
new
Processor\PushDelayedConnection
();
23
}
24
}
Bitrix\Calendar\Core\Queue\Agent\BaseAgent
Definition
baseagent.php:11
Bitrix\Calendar\Core\Queue\Agent\PushDelayedConnectionAgent
Definition
pushdelayedconnectionagent.php:12
Bitrix\Calendar\Core\Queue\Agent\PushDelayedConnectionAgent\getProcessor
getProcessor()
Definition
pushdelayedconnectionagent.php:20
Bitrix\Calendar\Core\Queue\Agent\PushDelayedConnectionAgent\getConsumer
getConsumer()
Definition
pushdelayedconnectionagent.php:13
Bitrix\Calendar\Core\Queue\Consumer\GroupHash
Definition
grouphash.php:15
Bitrix\Calendar\Core\Queue\Processor\PushDelayedConnection
Definition
pushdelayedconnection.php:15
Bitrix\Calendar\Core\Queue\Queue\QueueFactory
Definition
queuefactory.php:6
Bitrix\Calendar\Core\Queue\Queue\QueueRegistry
Definition
queueregistry.php:7
Bitrix\Calendar\Core\Queue\Interfaces\Consumer
Definition
consumer.php:6
Bitrix\Calendar\Core\Queue\Interfaces\Processor
Definition
processor.php:5
Bitrix\Calendar\Core\Queue\Agent
Definition
agententity.php:3
Bitrix\Calendar\Core\Queue\Consumer
Definition
grouphash.php:3
Bitrix\Calendar\Core\Queue\Interfaces
Definition
consumer.php:3
Bitrix\Calendar\Core\Queue\Processor
Definition
eventattendeesupdate.php:3
modules
calendar
lib
core
queue
agent
pushdelayedconnectionagent.php
Создано системой
1.10.0