PHP code example of proklung / bitrix.redis.module
1. Go to this page and download the library: Download proklung/bitrix.redis.module library. Choose the download type require.
2. Extract the ZIP file and open the index.php.
3. Add this code to the index.php.
<?php
require_once('vendor/autoload.php');
/* Start to develop here. Best regards https://php-download.com/ */
proklung / bitrix.redis.module example snippets
use Bitrix\Main\Loader;
use Proklung\Redis\DI\Services;
if (Loader::
use Interop\Queue\Message;
use Interop\Queue\Context;
use Interop\Queue\Processor;
use Enqueue\Client\TopicSubscriberInterface;
class FooRedisProcessor implements Processor, TopicSubscriberInterface
{
public function process(Message $message, Context $session)
{
file_put_contents($_SERVER['DOCUMENT_ROOT'] . '/redis-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-redis'];
}
}
use Interop\Queue\Message;
use Interop\Queue\Context;
use Interop\Queue\Processor;
use Enqueue\Client\TopicSubscriberInterface;
class FooFsProcessor implements Processor, TopicSubscriberInterface
{
public function process(Message $message, Context $session)
{
file_put_contents($_SERVER['DOCUMENT_ROOT'] . '/fs-bitrix.log', $message->getBody());
return self::ACK;
}
public static function getSubscribedTopics()
{
return ['bitrix-fs'];
}
}
/** @var Context $context */
$context = $container->get('enqueue.transport.filesystem.context');
$fooQueue = $context->createQueue('fs.fedy.default'); // См. .settings.php, свойства клиента.
$consumer = $context->createConsumer($fooQueue);
$message = $consumer->receiveNoWait(); // Для примера, чтобы скрипт не зацикливался. В нормальной среде - $consumer->receive().
$consumer->acknowledge($message);