Skip to content

Commit 76ed30a

Browse files
authored
Merge pull request #50 from Solution/feature/configurable-consumer
Extended queue configuration about necessary items
2 parents c09c332 + f5e935f commit 76ed30a

File tree

2 files changed

+6
-4
lines changed

2 files changed

+6
-4
lines changed

src/Kdyby/RabbitMq/BaseConsumer.php

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -90,10 +90,10 @@ protected function setupConsumer()
9090
$this->getChannel()->basic_consume(
9191
$this->queueOptions['name'],
9292
$this->getConsumerTag(),
93-
$noLocal = false,
94-
$noAck = false,
95-
$exclusive = false,
96-
$nowait = false,
93+
$this->queueOptions['noLocal'],
94+
$this->queueOptions['noAck'],
95+
$this->queueOptions['exclusive'],
96+
$this->queueOptions['nowait'],
9797
[$this, 'processMessage']
9898
);
9999
}

src/Kdyby/RabbitMq/DI/RabbitMqExtension.php

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -121,6 +121,8 @@ class RabbitMqExtension extends Nette\DI\CompilerExtension
121121
'name' => '',
122122
'passive' => FALSE,
123123
'durable' => TRUE,
124+
'noLocal' => FALSE,
125+
'noAck' => FALSE,
124126
'exclusive' => FALSE,
125127
'autoDelete' => FALSE,
126128
'nowait' => FALSE,

0 commit comments

Comments
 (0)