Skip to content

Commit 72a7e08

Browse files
committed
MC-35985: Enable new consumer configuration settings on current consumers
- Update tests;
1 parent 9f575f4 commit 72a7e08

File tree

2 files changed

+26
-17
lines changed

2 files changed

+26
-17
lines changed

app/code/Magento/MessageQueue/Test/Unit/Model/Cron/ConsumersRunnerTest.php

Lines changed: 25 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -153,7 +153,7 @@ public function testRun(
153153
['cron_consumers_runner/cron_run', true, true],
154154
['cron_consumers_runner/max_messages', 10000, $maxMessages],
155155
['cron_consumers_runner/consumers', [], $allowedConsumers],
156-
['queue/only_spawn_when_message_available', 0, 0],
156+
['queue/only_spawn_when_message_available', null, 0],
157157
]
158158
);
159159

@@ -277,14 +277,16 @@ public function runDataProvider()
277277
* @param int $shellBackgroundExpects
278278
* @param boolean $globalOnlySpawnWhenMessageAvailable
279279
* @param int $getOnlySpawnWhenMessageAvailableCallCount
280+
* @param int $isMassagesAvailableInTheQueueCallCount
280281
* @dataProvider runBasedOnOnlySpawnWhenMessageAvailableConsumerConfigurationDataProvider
281282
*/
282283
public function testRunBasedOnOnlySpawnWhenMessageAvailableConsumerConfiguration(
283284
$onlySpawnWhenMessageAvailable,
284285
$isMassagesAvailableInTheQueue,
285286
$shellBackgroundExpects,
286287
$globalOnlySpawnWhenMessageAvailable,
287-
$getOnlySpawnWhenMessageAvailableCallCount
288+
$getOnlySpawnWhenMessageAvailableCallCount,
289+
$isMassagesAvailableInTheQueueCallCount
288290
) {
289291
$consumerName = 'consumerName';
290292
$connectionName = 'connectionName';
@@ -296,7 +298,7 @@ public function testRunBasedOnOnlySpawnWhenMessageAvailableConsumerConfiguration
296298
['cron_consumers_runner/cron_run', true, true],
297299
['cron_consumers_runner/max_messages', 10000, 1000],
298300
['cron_consumers_runner/consumers', [], []],
299-
['queue/only_spawn_when_message_available', 0, $globalOnlySpawnWhenMessageAvailable],
301+
['queue/only_spawn_when_message_available', true, $globalOnlySpawnWhenMessageAvailable],
300302
]
301303
);
302304

@@ -323,7 +325,7 @@ public function testRunBasedOnOnlySpawnWhenMessageAvailableConsumerConfiguration
323325
->method('isLocked')
324326
->willReturn(false);
325327

326-
$this->checkIsAvailableMessagesMock->expects($this->exactly((int)$onlySpawnWhenMessageAvailable))
328+
$this->checkIsAvailableMessagesMock->expects($this->exactly($isMassagesAvailableInTheQueueCallCount))
327329
->method('execute')
328330
->willReturn($isMassagesAvailableInTheQueue);
329331

@@ -344,42 +346,48 @@ public function runBasedOnOnlySpawnWhenMessageAvailableConsumerConfigurationData
344346
'isMassagesAvailableInTheQueue' => true,
345347
'shellBackgroundExpects' => 1,
346348
'globalOnlySpawnWhenMessageAvailable' => false,
347-
'getOnlySpawnWhenMessageAvailableCallCount' => 1
349+
'getOnlySpawnWhenMessageAvailableCallCount' => 1,
350+
'isMassagesAvailableInTheQueueCallCount' => 1
348351
],
349352
[
350353
'onlySpawnWhenMessageAvailable' => true,
351354
'isMassagesAvailableInTheQueue' => false,
352355
'shellBackgroundExpects' => 0,
353356
'globalOnlySpawnWhenMessageAvailable' => false,
354-
'getOnlySpawnWhenMessageAvailableCallCount' => 1
357+
'getOnlySpawnWhenMessageAvailableCallCount' => 1,
358+
'isMassagesAvailableInTheQueueCallCount' => 1
355359
],
356360
[
357361
'onlySpawnWhenMessageAvailable' => false,
358362
'isMassagesAvailableInTheQueue' => true,
359363
'shellBackgroundExpects' => 1,
360364
'globalOnlySpawnWhenMessageAvailable' => false,
361-
'getOnlySpawnWhenMessageAvailableCallCount' => 1
365+
'getOnlySpawnWhenMessageAvailableCallCount' => 2,
366+
'isMassagesAvailableInTheQueueCallCount' => 0
362367
],
363368
[
364-
'onlySpawnWhenMessageAvailable' => false,
365-
'isMassagesAvailableInTheQueue' => false,
369+
'onlySpawnWhenMessageAvailable' => null,
370+
'isMassagesAvailableInTheQueue' => true,
366371
'shellBackgroundExpects' => 1,
367-
'globalOnlySpawnWhenMessageAvailable' => false,
368-
'getOnlySpawnWhenMessageAvailableCallCount' => 1
372+
'globalOnlySpawnWhenMessageAvailable' => true,
373+
'getOnlySpawnWhenMessageAvailableCallCount' => 2,
374+
'isMassagesAvailableInTheQueueCallCount' => 1
369375
],
370376
[
371-
'onlySpawnWhenMessageAvailable' => true,
377+
'onlySpawnWhenMessageAvailable' => null,
372378
'isMassagesAvailableInTheQueue' => true,
373379
'shellBackgroundExpects' => 1,
374-
'globalOnlySpawnWhenMessageAvailable' => true,
375-
'getOnlySpawnWhenMessageAvailableCallCount' => 0
380+
'globalOnlySpawnWhenMessageAvailable' => false,
381+
'getOnlySpawnWhenMessageAvailableCallCount' => 2,
382+
'isMassagesAvailableInTheQueueCallCount' => 0
376383
],
377384
[
378-
'onlySpawnWhenMessageAvailable' => true,
385+
'onlySpawnWhenMessageAvailable' => false,
379386
'isMassagesAvailableInTheQueue' => true,
380387
'shellBackgroundExpects' => 1,
381-
'globalOnlySpawnWhenMessageAvailable' => false,
382-
'getOnlySpawnWhenMessageAvailableCallCount' => 1
388+
'globalOnlySpawnWhenMessageAvailable' => true,
389+
'getOnlySpawnWhenMessageAvailableCallCount' => 2,
390+
'isMassagesAvailableInTheQueueCallCount' => 0
383391
],
384392
];
385393
}

dev/tests/integration/testsuite/Magento/MessageQueue/Model/Cron/ConsumersRunnerTest.php

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -127,6 +127,7 @@ public function testSpecificConsumerAndRerun()
127127
$specificConsumer = 'exportProcessor';
128128
$config = $this->config;
129129
$config['cron_consumers_runner'] = ['consumers' => [$specificConsumer], 'max_messages' => 0];
130+
$config['queue'] = ['only_spawn_when_message_available' => 0];
130131
$this->writeConfig($config);
131132
$this->reRunConsumersAndCheckLocks($specificConsumer);
132133
$this->reRunConsumersAndCheckLocks($specificConsumer);

0 commit comments

Comments
 (0)