Skip to content

Commit 3586267

Browse files
committed
[async-commands][async-events] Sync with latest design chagnes in core.
1 parent c6d4a46 commit 3586267

File tree

3 files changed

+7
-8
lines changed

3 files changed

+7
-8
lines changed

Resources/config/services.yml

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,7 @@
11
services:
22
enqueue.async_command.run_command_processor:
33
class: 'Enqueue\AsyncCommand\RunCommandProcessor'
4-
public: public
54
arguments:
65
- '%kernel.project_dir%'
76
tags:
8-
- { name: 'enqueue.client.processor' }
7+
- { name: 'enqueue.command_subscriber', client: 'default' }

RunCommandProcessor.php

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -45,9 +45,9 @@ public function process(PsrMessage $message, PsrContext $context): Result
4545
public static function getSubscribedCommand(): array
4646
{
4747
return [
48-
'processorName' => Commands::RUN_COMMAND,
49-
'queueName' => Commands::RUN_COMMAND,
50-
'queueNameHardcoded' => true,
48+
'command' => Commands::RUN_COMMAND,
49+
'queue' => Commands::RUN_COMMAND,
50+
'prefix_queue' => false,
5151
'exclusive' => true,
5252
];
5353
}

Tests/RunCommandProcessorTest.php

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -43,9 +43,9 @@ public function testShouldSubscribeOnRunCommand()
4343
$subscription = RunCommandProcessor::getSubscribedCommand();
4444

4545
$this->assertSame([
46-
'processorName' => Commands::RUN_COMMAND,
47-
'queueName' => Commands::RUN_COMMAND,
48-
'queueNameHardcoded' => true,
46+
'command' => Commands::RUN_COMMAND,
47+
'queue' => Commands::RUN_COMMAND,
48+
'prefix_queue' => false,
4949
'exclusive' => true,
5050
], $subscription);
5151
}

0 commit comments

Comments
 (0)