RabbitMq transport

Author: ProklUng

.settings.php

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

lib/Samples/FooRabbitProcessor.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 FooRabbitProcessor
+ * @package Proklung\Redis\Samples
+ */
+class FooRabbitProcessor implements Processor, TopicSubscriberInterface
+{
+    public function process(Message $message, Context $session)
+    {
+        file_put_contents($_SERVER['DOCUMENT_ROOT'] . '/rabbit-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 ['bitrix-rabbit'];
+    }
+}

readme.MD

@@ -1,6 +1,9 @@
 # Модуль для Битрикса, организующий работу с очередями через Redis (и не только)
 
+Поддерживаемый транспорт:
+
 - Redis
+- RabbitMq
 - Filesystem
 
 ## Установка
@@ -194,6 +197,46 @@ return [
 
 ## Другие транспорты
 
+### RabbitMq
+
+#### Настройка
+
+`.settings.php` Битрикса:
+
+```php
+// ... предыдущее
+
+    'proklung.redis' => [
+        'value' => [
+            'enqueue' => [
+                // ... предыдущее
+                'rabbit' => [
+                    'transport' => 'amqp://',
+                    'client' => [
+                        'default_queue' => 'default',
+                        'prefix' => 'rabbit',
+                        'app_name' => 'fedy',
+                    ],
+                ],
+            ]
+        ]
+    ],
+```
+
+Все по аналогии с Redis или файловой системой. Важно первый раз не забыть запустить `setup-broker`:
+
+```bash
+php bin/enqueue enqueue:setup-broker --client=rabbit
+```
+
+#### Получение сообщений
+
+```bash
+php bin/enqueue enqueue:consume --client=rabbit
+```
+
+Где `rabbit` - название клиента, определяемое в `.settings.php` Битрикса.
+
 ### Файловая система
 
 #### Настройка