DBAL транспорт.

Author: ProklUng

.settings.php

@@ -25,6 +25,11 @@
                 'className' => \Proklung\Redis\Samples\FooRabbitProcessor::class,
                 'tags' => ['name' => 'enqueue.topic_subscriber', 'client' => 'rabbit']
             ],
+            // Пример клиента на Dbal
+            'Proklung\Redis\Samples\FooDbalProcessor' => [
+                'className' => \Proklung\Redis\Samples\FooDbalProcessor::class,
+                'tags' => ['name' => 'enqueue.topic_subscriber', 'client' => 'dbal']
+            ],
         ],
         'readonly' => false,
     ],

install/version.php

@@ -1,6 +1,6 @@
 <?php
 
 $arModuleVersion = [
-    'VERSION' 		=> '1.2.0',
-    'VERSION_DATE' 	=> '2021-07-16'
+    'VERSION' 		=> '1.2.1',
+    'VERSION_DATE' 	=> '2021-07-18'
 ];

lang/ru/install/index.php

@@ -1,6 +1,6 @@
 <?php
 
-$MESS['REDIS_MODULE_NAME'] = 'Очереди на Redis (и на RabbitMq, и Filesystem)';
-$MESS['REDIS_MODULE_DESCRIPTION'] = 'Очереди на Redis (и на RabbitMq, и Filesystem)';
+$MESS['REDIS_MODULE_NAME'] = 'Очереди на Redis (и на RabbitMq, и Filesystem, и через DBAL)';
+$MESS['REDIS_MODULE_DESCRIPTION'] = 'Очереди на Redis (и на RabbitMq, и Filesystem, и через DBAL)';
 $MESS['REDIS_MODULE_PARTNER_NAME'] = 'ProklUng';
 $MESS['REDIS_MODULE_PARTNER_URI'] = 'https://github.com/ProklUng/bitrix.redis.module';

lib/Samples/FooDbalProcessor.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace Proklung\Redis\Samples;
+
+use Interop\Queue\Message;
+use Interop\Queue\Context;
+use Interop\Queue\Processor;
+use Enqueue\Client\TopicSubscriberInterface;
+
+/**
+ * Class FooDbalProcessor
+ * @package Proklung\Redis\Samples
+ */
+class FooDbalProcessor implements Processor, TopicSubscriberInterface
+{
+    public function process(Message $message, Context $session)
+    {
+        file_put_contents($_SERVER['DOCUMENT_ROOT'] . '/dbal-bitrix.log', $message->getBody());
+
+        return self::ACK;
+        // return self::REJECT; // when the message is broken
+        // return self::REQUEUE; // the message is fine but you want to postpone processing
+    }
+
+    public static function getSubscribedTopics()
+    {
+        return ['dbal-event'];
+    }
+}

readme.MD

@@ -5,7 +5,7 @@
 - Redis
 - RabbitMq
 - Filesystem
-
+- DBAL
 ## Установка
 
 composer.json основного проекта:
@@ -237,6 +237,52 @@ php bin/enqueue enqueue:consume --client=rabbit
 
 Где `rabbit` - название клиента, определяемое в `.settings.php` Битрикса.
 
+### DBAL
+
+#### Установка
+
+Дабы не отягощать модуль зависимостями - `enqueue/dbal` не включен в стандартный `composer.json`. Для использования
+этого транспорта нужно самолично запустить `composer require enqueue/dbal` в конечном проекте.
+
+#### Настройка
+
+`.settings.php` Битрикса:
+
+```php
+// ... предыдущее
+
+    'proklung.redis' => [
+        'value' => [
+            'enqueue' => [
+                // ... предыдущее
+                'dbal' => [
+                    'transport' => 'mysql://root:@localhost/bitrix.loc',
+                    'client' => [
+                        'default_queue' => 'default',
+                        'prefix' => 'dbal',
+                        'app_name' => 'fedy',
+                    ],
+                ],
+            ]
+        ]
+    ],
+```
+
+Все по аналогии с Redis или файловой системой. Важно первый раз не забыть запустить `setup-broker` (будет создана
+таблица `enqueue`):
+
+```bash
+php bin/enqueue enqueue:setup-broker --client=dbal
+```
+
+#### Получение сообщений
+
+```bash
+php bin/enqueue enqueue:consume --client=dbal
+```
+
+Где `dbal` - название клиента, определяемое в `.settings.php` Битрикса.
+
 ### Файловая система
 
 #### Настройка