thecodingmachine / oo-amqp-client

src/Objects/Exchange.php

Unused Use Statements -1 removed lines

@@ -5,7 +5,6 @@
 use Mouf\AmqpClient\Client;
 use Mouf\AmqpClient\RabbitMqObjectInterface;
 use PhpAmqpLib\Channel\AMQPChannel;
-use PhpAmqpLib\Message\AMQPMessage;
 
 class Exchange implements RabbitMqObjectInterface
 {

src/Objects/Queue.php

Spacing +10 added lines, -10 removed lines

@@ -8,7 +8,7 @@ 
  * @author Marc
  *
  */
-class Queue implements RabbitMqObjectInterface{
+class Queue implements RabbitMqObjectInterface {
 
 	/**
 	 * 
@@ -384,34 +384,34 @@ 
 	
 	
 	public function init(AMQPChannel $amqpChannel) {
-		if(!$this->init) {
+		if (!$this->init) {
 			$this->source->init($amqpChannel);
 			$this->deadLetterQueue->init($amqpChannel);
 			
 			$parameters = [];
-			if($this->alternateExchange !== null) {
+			if ($this->alternateExchange !== null) {
 				$parameters['alternate-exchange'] = $this->alternateExchange->getName();
 			}
-			if($this->confirm !== null) {
+			if ($this->confirm !== null) {
 				$parameters['confirm'] = $this->confirm;
 			}
-			if($this->consumerCancelNotify !== null) {
+			if ($this->consumerCancelNotify !== null) {
 				$parameters['consumer_cancel_notify'] = $this->consumerCancelNotify;
 			}
-			if($this->deadLetterQueue !== null) {
+			if ($this->deadLetterQueue !== null) {
 				$parameters['x-dead-letter-exchange'] = $this->deadLetterQueue->getName();
 			}
-			if($this->maxLength) {
+			if ($this->maxLength) {
 				$parameters['x-max-length'] = $this->maxLength;
 			}
-			if($this->maxPriority) {
+			if ($this->maxPriority) {
 				$parameters['x-max-priority'] = $this->maxPriority;
 			}
-			if($this->ttl) {
+			if ($this->ttl) {
 				$parameters['x-message-ttl'] = $this->ttl;
 			}
 			
-			if(!$parameters) {
+			if (!$parameters) {
 				$parameters = null;
 			}
 			$amqpChannel->queue_declare($this->name, $this->passive, $this->durable, $this->exclusive, $this->autoDelete, $this->noWait, $parameters);