Skip to content

Commit 591f889

Browse files
authored
Merge pull request #122 from php-enqueue/fix-dbal-polling-interval-config
fix dbal polling interval configuration option
2 parents f0292ca + 974de6a commit 591f889

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

Diff for: pkg/dbal/DbalContext.php

+2-2
Original file line numberDiff line numberDiff line change
@@ -115,8 +115,8 @@ public function createConsumer(PsrDestination $destination)
115115

116116
$consumer = new DbalConsumer($this, $destination);
117117

118-
if (isset($this->config['pollingInterval'])) {
119-
$consumer->setPollingInterval($this->config['pollingInterval']);
118+
if (isset($this->config['polling_interval'])) {
119+
$consumer->setPollingInterval($this->config['polling_interval']);
120120
}
121121

122122
return $consumer;

Diff for: pkg/dbal/Tests/DbalContextTest.php

+1-1
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@ public function testShouldCreateConsumer()
9898
public function testShouldCreateMessageConsumerAndSetPollingInterval()
9999
{
100100
$context = new DbalContext($this->createConnectionMock(), [
101-
'pollingInterval' => 123456,
101+
'polling_interval' => 123456,
102102
]);
103103

104104
$consumer = $context->createConsumer(new DbalDestination(''));

0 commit comments

Comments
 (0)