Skip to content

Commit 7722d32

Browse files
committed
Fixes
1 parent 1546a1e commit 7722d32

File tree

3 files changed

+6
-3
lines changed

3 files changed

+6
-3
lines changed

README.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -196,6 +196,7 @@ class UploadPictureConsumer implements ConsumerInterface
196196
* `bitrix-rabbitmq:purge` Purge a consumer's queue
197197
* `bitrix-abbitmq:setup-fabric` Sets up the Rabbit MQ fabric
198198
* `bitrix-rabbitmq:stdin-producer` Executes a producer that reads data from STDIN
199+
* `bitrix-rabbitmq:rpc-server` Start RPC server
199200

200201
В папке `/install/bin` модуля лежит файл `rabbitmq`. При установке модуля система попробует скопировать его в директорию,
201202
`bin`, лежащую двумя уровнями выше `DOCUMENT_ROOT`. Если такой директории не существует, то сделано ничего не будет. Придется

install/bin/rabbitmq

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@ define('NO_AGENT_STATISTIC', 'Y');
2626
define('NO_AGENT_CHECK', true);
2727
defined('PUBLIC_AJAX_MODE') || define('PUBLIC_AJAX_MODE', true);
2828

29-
3029
/** @noinspection PhpIncludeInspection */
3130
require_once $autoloadPath;
3231

@@ -63,7 +62,10 @@ if ($bitrixStatus !== 200) {
6362

6463
Loader::includeModule('proklung.rabbitmq');
6564

66-
$commands = CommandsSetup::load(Services::getInstance());
65+
$services = new Services();
66+
$services->load();
67+
68+
$commands = CommandsSetup::load($services->getContainer());
6769

6870
$application = new ConsoleCommandConfigurator(
6971
new Application(),

lib/Command/RpcServerCommand.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
4242
}
4343

4444
$this->getContainer()
45-
->get(sprintf('old_sound_rabbit_mq.%s_server', $input->getArgument('name')))
45+
->get(sprintf('rabbitmq.%s_server', $input->getArgument('name')))
4646
->start($amount);
4747

4848
return 0;

0 commit comments

Comments
 (0)