Skip to content

Commit

Permalink
ECP-515: Storefront Get API
Browse files Browse the repository at this point in the history
    - fix tests
  • Loading branch information
le0n4ik committed Jun 23, 2020
1 parent 734fb51 commit ce5757d
Showing 1 changed file with 11 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -66,14 +66,21 @@ protected function setUp(): void
*/
public function testWaitForMessages()
{
$this->assertArrayHasKey('queue', $this->config);
$this->assertArrayHasKey('consumers_wait_for_messages', $this->config['queue']);
$this->assertEquals(1, $this->config['queue']['consumers_wait_for_messages']);
$this->publisherConsumerController->stopConsumers();

$config = $this->config;
$config['queue']['consumers_wait_for_messages'] = 1;
$this->writeConfig($config);

$loadedConfig = $this->loadConfig();
$this->assertArrayHasKey('queue', $loadedConfig);
$this->assertArrayHasKey('consumers_wait_for_messages', $loadedConfig['queue']);
$this->assertEquals(1, $loadedConfig['queue']['consumers_wait_for_messages']);

foreach ($this->messages as $message) {
$this->publishMessage($message);
}

$this->publisherConsumerController->startConsumers();
$this->waitForAsynchronousResult(count($this->messages), $this->logFilePath);

foreach ($this->messages as $item) {
Expand Down

0 comments on commit ce5757d

Please sign in to comment.