@@ -8,7 +8,7 @@ discard block |
||
8 | 8 | * @author Marc |
9 | 9 | * |
10 | 10 | */ |
11 | -class Queue implements RabbitMqObjectInterface{ |
|
11 | +class Queue implements RabbitMqObjectInterface { |
|
12 | 12 | |
13 | 13 | /** |
14 | 14 | * |
@@ -384,34 +384,34 @@ discard block |
||
384 | 384 | |
385 | 385 | |
386 | 386 | public function init(AMQPChannel $amqpChannel) { |
387 | - if(!$this->init) { |
|
387 | + if (!$this->init) { |
|
388 | 388 | $this->source->init($amqpChannel); |
389 | 389 | $this->deadLetterQueue->init($amqpChannel); |
390 | 390 | |
391 | 391 | $parameters = []; |
392 | - if($this->alternateExchange !== null) { |
|
392 | + if ($this->alternateExchange !== null) { |
|
393 | 393 | $parameters['alternate-exchange'] = $this->alternateExchange->getName(); |
394 | 394 | } |
395 | - if($this->confirm !== null) { |
|
395 | + if ($this->confirm !== null) { |
|
396 | 396 | $parameters['confirm'] = $this->confirm; |
397 | 397 | } |
398 | - if($this->consumerCancelNotify !== null) { |
|
398 | + if ($this->consumerCancelNotify !== null) { |
|
399 | 399 | $parameters['consumer_cancel_notify'] = $this->consumerCancelNotify; |
400 | 400 | } |
401 | - if($this->deadLetterQueue !== null) { |
|
401 | + if ($this->deadLetterQueue !== null) { |
|
402 | 402 | $parameters['x-dead-letter-exchange'] = $this->deadLetterQueue->getName(); |
403 | 403 | } |
404 | - if($this->maxLength) { |
|
404 | + if ($this->maxLength) { |
|
405 | 405 | $parameters['x-max-length'] = $this->maxLength; |
406 | 406 | } |
407 | - if($this->maxPriority) { |
|
407 | + if ($this->maxPriority) { |
|
408 | 408 | $parameters['x-max-priority'] = $this->maxPriority; |
409 | 409 | } |
410 | - if($this->ttl) { |
|
410 | + if ($this->ttl) { |
|
411 | 411 | $parameters['x-message-ttl'] = $this->ttl; |
412 | 412 | } |
413 | 413 | |
414 | - if(!$parameters) { |
|
414 | + if (!$parameters) { |
|
415 | 415 | $parameters = null; |
416 | 416 | } |
417 | 417 | $amqpChannel->queue_declare($this->name, $this->passive, $this->durable, $this->exclusive, $this->autoDelete, $this->noWait, $parameters); |