Completed
Push — 1.0 ( 7ed330...095234 )
by David
02:56
created
src/Objects/Queue.php 1 patch
Spacing   +10 added lines, -10 removed lines patch added patch discarded remove patch
@@ -8,7 +8,7 @@  discard block
 block discarded – undo
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
 block discarded – undo
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);
Please login to merge, or discard this patch.