thecodingmachine / oo-amqp-client

src/Objects/Exchange.php

Doc Comments +3 added lines, -1 removed lines

@@ -87,7 +87,6 @@ 
     /**
      * Set the to (Binding).
      *
-     * @param Binding $to
      * @param string  $name
      * @param string  $type direct, topic, headers or fanout
      */
@@ -292,6 +291,9 @@ 
         }
     }
 
+    /**
+     * @param string $routingKey
+     */
     public function publish(Message $message, $routingKey, $mandatory = false,
                             $immediate = false,
                             $ticket = null)

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

Doc Comments -1 removed lines

@@ -356,7 +356,6 @@
 	
 	/**
 	 * Set RabbitMq specific parameter : max length
-	 * @param int $ttl
 	 * @return Queue
 	 */
 	public function setMaxLength($maxLength) {

Indentation +405 added lines, -405 removed lines

@@ -10,418 +10,418 @@
  */
 class Queue implements RabbitMqObjectInterface{
 
-	/**
-	 * 
-	 * @var Binding
-	 */
-	private $source;
-	
-	/**
-	 * Queue name
-	 * @var String
-	 */
-	private $name;
-	
-	/**
-	 * Queue
-	 * @var string
-	 */
-	private $queue = '';
-	
-	/**
-	 * Passive
-	 * @var bool
-	 */
-	private $passive = false;
-	
-	/**
-	 * Durable
-	 * @var bool
-	 */
-	private $durable = false;
-	
-	/**
-	 * Exclusive
-	 * @var bool
-	 */
-	private $exclusive = false;
-	
-	/**
-	 * Auto delete
-	 * @var bool
-	 */
-	private $autoDelete = false;
-	
-	/**
-	 * No wait
-	 * @var bool
-	 */
-	private $autoDelete = false;
-	
-	/**
-	 * Ticket
-	 * @var int
-	 */
-	private $ticket = null;
-	
-	/**
-	 *R abbitMq specific parameter : x-dead-letter-exchange
-	 * @var Queue
-	 */
-	private $deadLetterQueue = null;
-	
-	/**
-	 * RabbitMq specific parameter : confirm
-	 * @var int
-	 */
-	private $confirm = null;
-	
-	/**
-	 * RabbitMq specific parameter : consumer_cancel_notify 
-	 * @var bool
-	 */
-	private $consumerCancelNotify = null;
-	
-	/**
-	 * RabbitMq specific parameter : alternate-exchange 
-	 * @var Queue
-	 */
-	private $alternateExchange = null;
-	
-	/**
-	 * RabbitMq specific parameter : x-message-ttl 
-	 * @var int
-	 */
-	private $ttl = null;
-	
-	/**
-	 * RabbitMq specific parameter : x-max-length 
-	 * @var int
-	 */
-	private $maxLength = null;
-	
-	/**
-	 * RabbitMq specific parameter : x-max-priority 
-	 * @var int
-	 */
-	private $maxPriority = null;
-	
-	/**
-	 * Parameter to initialize object only one time
-	 * @var bool
-	 */
-	private $init = false;
-	
-	/**
-	 * Set the source (Binding)
-	 * @param Binding $source
-	 * @param string $name
-	 */
-	public function __contruct(Binding $source, $name) {
-		$this->source = $source;
-		$this->name = $name;
-	}
+    /**
+     * 
+     * @var Binding
+     */
+    private $source;
+	
+    /**
+     * Queue name
+     * @var String
+     */
+    private $name;
+	
+    /**
+     * Queue
+     * @var string
+     */
+    private $queue = '';
+	
+    /**
+     * Passive
+     * @var bool
+     */
+    private $passive = false;
+	
+    /**
+     * Durable
+     * @var bool
+     */
+    private $durable = false;
+	
+    /**
+     * Exclusive
+     * @var bool
+     */
+    private $exclusive = false;
+	
+    /**
+     * Auto delete
+     * @var bool
+     */
+    private $autoDelete = false;
+	
+    /**
+     * No wait
+     * @var bool
+     */
+    private $autoDelete = false;
+	
+    /**
+     * Ticket
+     * @var int
+     */
+    private $ticket = null;
+	
+    /**
+     *R abbitMq specific parameter : x-dead-letter-exchange
+     * @var Queue
+     */
+    private $deadLetterQueue = null;
+	
+    /**
+     * RabbitMq specific parameter : confirm
+     * @var int
+     */
+    private $confirm = null;
+	
+    /**
+     * RabbitMq specific parameter : consumer_cancel_notify 
+     * @var bool
+     */
+    private $consumerCancelNotify = null;
+	
+    /**
+     * RabbitMq specific parameter : alternate-exchange 
+     * @var Queue
+     */
+    private $alternateExchange = null;
+	
+    /**
+     * RabbitMq specific parameter : x-message-ttl 
+     * @var int
+     */
+    private $ttl = null;
+	
+    /**
+     * RabbitMq specific parameter : x-max-length 
+     * @var int
+     */
+    private $maxLength = null;
+	
+    /**
+     * RabbitMq specific parameter : x-max-priority 
+     * @var int
+     */
+    private $maxPriority = null;
+	
+    /**
+     * Parameter to initialize object only one time
+     * @var bool
+     */
+    private $init = false;
+	
+    /**
+     * Set the source (Binding)
+     * @param Binding $source
+     * @param string $name
+     */
+    public function __contruct(Binding $source, $name) {
+        $this->source = $source;
+        $this->name = $name;
+    }
 
-	/**
-	 * Get queue name
-	 * @return string
-	 */
-	public function getName() {
-		return $this->name;
-	}
+    /**
+     * Get queue name
+     * @return string
+     */
+    public function getName() {
+        return $this->name;
+    }
 
-	/**
-	 * Get passive
-	 * @return bool
-	 */
-	public function getPassive() {
-		return $this->passive;
-	}
-	
-	/**
-	 *
-	 * @param bool $passive
-	 * @return Queue
-	 */
-	public function setPassive($passive) {
-		$this->passive = $passive;
-		return $this;
-	}
-	
-	/**
-	 * Get durable
-	 * @return bool
-	 */
-	public function getDurable() {
-		return $this->durable;
-	}
-	
-	/**
-	 * Set durable
-	 * @param bool $durable
-	 * @return Queue
-	 */
-	public function setDurable($durable) {
-		$this->durable = $durable;
-		return $this;
-	}
-	
-	/**
-	 * Get exclusive
-	 * @return bool
-	 */
-	public function getExclusive() {
-		return $this->exclusive;
-	}
-	
-	/**
-	 * Set exclusive
-	 * @param bool $exclusive
-	 * @return Queue
-	 */
-	public function setExclusive($exclusive) {
-		$this->exclusive = $exclusive;
-		return $this;
-	}
-	
-	/**
-	 * Get autoDelete
-	 * @return bool
-	 */
-	public function getAutoDelete() {
-		return $this->autoDelete;
-	}
-	
-	/**
-	 * Set autoDelete
-	 * @param bool $autoDelete
-	 * @return Queue
-	 */
-	public function setAutoDelete($autoDelete) {
-		$this->autoDelete = $autoDelete;
-		return $this;
-	}
-	
-	/**
-	 * Get noWait
-	 * @return bool
-	 */
-	public function getNoWait() {
-		return $this->noWait;
-	}
-	
-	/**
-	 * Set noWait
-	 * @param bool $noWait
-	 * @return Queue
-	 */
-	public function setNoWait($noWait) {
-		$this->noWait = $noWait;
-		return $this;
-	}
-	
-	/**
-	 * Get arguments
-	 * @return array|null
-	 */
-	public function getArguments() {
-		return $this->arguments;
-	}
-	
-	/**
-	 * Set arguments
-	 * @param array $arguments
-	 * @return Queue
-	 */
-	public function setArguments($arguments) {
-		$this->arguments = $arguments;
-		return $this;
-	}
-	
-	/**
-	 * Get ticket
-	 * @return int
-	 */
-	public function getTicket() {
-		return $this->ticket;
-	}
-	
-	/**
-	 * Set ticket
-	 * @param int $ticket
-	 * @return Queue
-	 */
-	public function setTicket($ticket) {
-		$this->ticket = $ticket;
-		return $this;
-	}
+    /**
+     * Get passive
+     * @return bool
+     */
+    public function getPassive() {
+        return $this->passive;
+    }
+	
+    /**
+     *
+     * @param bool $passive
+     * @return Queue
+     */
+    public function setPassive($passive) {
+        $this->passive = $passive;
+        return $this;
+    }
+	
+    /**
+     * Get durable
+     * @return bool
+     */
+    public function getDurable() {
+        return $this->durable;
+    }
+	
+    /**
+     * Set durable
+     * @param bool $durable
+     * @return Queue
+     */
+    public function setDurable($durable) {
+        $this->durable = $durable;
+        return $this;
+    }
+	
+    /**
+     * Get exclusive
+     * @return bool
+     */
+    public function getExclusive() {
+        return $this->exclusive;
+    }
+	
+    /**
+     * Set exclusive
+     * @param bool $exclusive
+     * @return Queue
+     */
+    public function setExclusive($exclusive) {
+        $this->exclusive = $exclusive;
+        return $this;
+    }
+	
+    /**
+     * Get autoDelete
+     * @return bool
+     */
+    public function getAutoDelete() {
+        return $this->autoDelete;
+    }
+	
+    /**
+     * Set autoDelete
+     * @param bool $autoDelete
+     * @return Queue
+     */
+    public function setAutoDelete($autoDelete) {
+        $this->autoDelete = $autoDelete;
+        return $this;
+    }
+	
+    /**
+     * Get noWait
+     * @return bool
+     */
+    public function getNoWait() {
+        return $this->noWait;
+    }
+	
+    /**
+     * Set noWait
+     * @param bool $noWait
+     * @return Queue
+     */
+    public function setNoWait($noWait) {
+        $this->noWait = $noWait;
+        return $this;
+    }
+	
+    /**
+     * Get arguments
+     * @return array|null
+     */
+    public function getArguments() {
+        return $this->arguments;
+    }
+	
+    /**
+     * Set arguments
+     * @param array $arguments
+     * @return Queue
+     */
+    public function setArguments($arguments) {
+        $this->arguments = $arguments;
+        return $this;
+    }
+	
+    /**
+     * Get ticket
+     * @return int
+     */
+    public function getTicket() {
+        return $this->ticket;
+    }
+	
+    /**
+     * Set ticket
+     * @param int $ticket
+     * @return Queue
+     */
+    public function setTicket($ticket) {
+        $this->ticket = $ticket;
+        return $this;
+    }
 
-	/**
-	 * Get RabbitMq specific parameter : dead letter queue
-	 * @return Queue
-	 */
-	public function getDeadLetterQueue() {
-		return $this->deadLetterQueue;
-	}
-	
-	/**
-	 * Set RabbitMq specific parameter : dead letter queue
-	 * @param Queue $queue
-	 * @return Queue
-	 */
-	public function setDeadLetterQueue(Queue $queue) {
-		$this->deadLetterQueue = $queue;
-		return $this;
-	}
-	
-	/**
-	 * Get RabbitMq specific parameter : confirm
-	 * @return int
-	 */
-	public function getConfirm() {
-		return $this->confirm;
-	}
-	
-	/**
-	 * Set RabbitMq specific parameter : confirm
-	 * @param int $confirm
-	 * @return Queue
-	 */
-	public function setConfirm($confirm) {
-		$this->confirm = $confirm;
-		return $this;
-	}
-	
-	/**
-	 * Get RabbitMq specific parameter : consumer_cancel_notify
-	 * @return bool
-	 */
-	public function getConsumerCancelNotify() {
-		return $this->consumerCancelNotify;
-	}
-	
-	/**
-	 * Set RabbitMq specific parameter : consumer_cancel_notify
-	 * @param Queue $consumerCancelNotify
-	 * @return Queue
-	 */
-	public function setConsumerCancelNotify(Queue $consumerCancelNotify) {
-		$this->consumerCancelNotify = $consumerCancelNotify;
-		return $this;
-	}
-	
-	/**
-	 * Get RabbitMq specific parameter : alternate_exchange
-	 * @return Queue
-	 */
-	public function getAlternateExchange() {
-		return $this->alternateExchange;
-	}
-	
-	/**
-	 * Set RabbitMq specific parameter : alternate_exchange
-	 * @param Queue $alternateExchange
-	 * @return Queue
-	 */
-	public function setAlternateExchange(Queue $alternateExchange) {
-		$this->alternateExchange = $alternateExchange;
-		return $this;
-	}
-	
-	/**
-	 * Get RabbitMq specific parameter : ttl
-	 * @return int
-	 */
-	public function getTtl() {
-		return $this->ttl;
-	}
-	
-	/**
-	 * Set RabbitMq specific parameter : ttl
-	 * @param int $ttl
-	 * @return Queue
-	 */
-	public function setTtl($ttl) {
-		$this->ttl = $ttl;
-		return $this;
-	}
-	
-	/**
-	 * Get RabbitMq specific parameter : max length
-	 * @return int
-	 */
-	public function getMaxLength() {
-		return $this->maxLength;
-	}
-	
-	/**
-	 * Set RabbitMq specific parameter : max length
-	 * @param int $ttl
-	 * @return Queue
-	 */
-	public function setMaxLength($maxLength) {
-		$this->maxLength = $maxLength;
-		return $this;
-	}
-	
-	/**
-	 * Get RabbitMq specific parameter : max priority
-	 * @return int
-	 */
-	public function getMaxPriority() {
-		return $this->maxPriority;
-	}
-	
-	/**
-	 * Set RabbitMq specific parameter : max priority
-	 * @param int $maxPriority
-	 * @return Queue
-	 */
-	public function setMaxPriority($maxPriority) {
-		$this->maxPriority = $maxPriority;
-		return $this;
-	}
-	
-	
-	public function init(AMQPChannel $amqpChannel) {
-		if(!$this->init) {
-			$this->source->init($amqpChannel);
-			$this->deadLetterQueue->init($amqpChannel);
+    /**
+     * Get RabbitMq specific parameter : dead letter queue
+     * @return Queue
+     */
+    public function getDeadLetterQueue() {
+        return $this->deadLetterQueue;
+    }
+	
+    /**
+     * Set RabbitMq specific parameter : dead letter queue
+     * @param Queue $queue
+     * @return Queue
+     */
+    public function setDeadLetterQueue(Queue $queue) {
+        $this->deadLetterQueue = $queue;
+        return $this;
+    }
+	
+    /**
+     * Get RabbitMq specific parameter : confirm
+     * @return int
+     */
+    public function getConfirm() {
+        return $this->confirm;
+    }
+	
+    /**
+     * Set RabbitMq specific parameter : confirm
+     * @param int $confirm
+     * @return Queue
+     */
+    public function setConfirm($confirm) {
+        $this->confirm = $confirm;
+        return $this;
+    }
+	
+    /**
+     * Get RabbitMq specific parameter : consumer_cancel_notify
+     * @return bool
+     */
+    public function getConsumerCancelNotify() {
+        return $this->consumerCancelNotify;
+    }
+	
+    /**
+     * Set RabbitMq specific parameter : consumer_cancel_notify
+     * @param Queue $consumerCancelNotify
+     * @return Queue
+     */
+    public function setConsumerCancelNotify(Queue $consumerCancelNotify) {
+        $this->consumerCancelNotify = $consumerCancelNotify;
+        return $this;
+    }
+	
+    /**
+     * Get RabbitMq specific parameter : alternate_exchange
+     * @return Queue
+     */
+    public function getAlternateExchange() {
+        return $this->alternateExchange;
+    }
+	
+    /**
+     * Set RabbitMq specific parameter : alternate_exchange
+     * @param Queue $alternateExchange
+     * @return Queue
+     */
+    public function setAlternateExchange(Queue $alternateExchange) {
+        $this->alternateExchange = $alternateExchange;
+        return $this;
+    }
+	
+    /**
+     * Get RabbitMq specific parameter : ttl
+     * @return int
+     */
+    public function getTtl() {
+        return $this->ttl;
+    }
+	
+    /**
+     * Set RabbitMq specific parameter : ttl
+     * @param int $ttl
+     * @return Queue
+     */
+    public function setTtl($ttl) {
+        $this->ttl = $ttl;
+        return $this;
+    }
+	
+    /**
+     * Get RabbitMq specific parameter : max length
+     * @return int
+     */
+    public function getMaxLength() {
+        return $this->maxLength;
+    }
+	
+    /**
+     * Set RabbitMq specific parameter : max length
+     * @param int $ttl
+     * @return Queue
+     */
+    public function setMaxLength($maxLength) {
+        $this->maxLength = $maxLength;
+        return $this;
+    }
+	
+    /**
+     * Get RabbitMq specific parameter : max priority
+     * @return int
+     */
+    public function getMaxPriority() {
+        return $this->maxPriority;
+    }
+	
+    /**
+     * Set RabbitMq specific parameter : max priority
+     * @param int $maxPriority
+     * @return Queue
+     */
+    public function setMaxPriority($maxPriority) {
+        $this->maxPriority = $maxPriority;
+        return $this;
+    }
+	
+	
+    public function init(AMQPChannel $amqpChannel) {
+        if(!$this->init) {
+            $this->source->init($amqpChannel);
+            $this->deadLetterQueue->init($amqpChannel);
 			
-			$parameters = [];
-			if($this->alternateExchange !== null) {
-				$parameters['alternate-exchange'] = $this->alternateExchange->getName();
-			}
-			if($this->confirm !== null) {
-				$parameters['confirm'] = $this->confirm;
-			}
-			if($this->consumerCancelNotify !== null) {
-				$parameters['consumer_cancel_notify'] = $this->consumerCancelNotify;
-			}
-			if($this->deadLetterQueue !== null) {
-				$parameters['x-dead-letter-exchange'] = $this->deadLetterQueue->getName();
-			}
-			if($this->maxLength) {
-				$parameters['x-max-length'] = $this->maxLength;
-			}
-			if($this->maxPriority) {
-				$parameters['x-max-priority'] = $this->maxPriority;
-			}
-			if($this->ttl) {
-				$parameters['x-message-ttl'] = $this->ttl;
-			}
+            $parameters = [];
+            if($this->alternateExchange !== null) {
+                $parameters['alternate-exchange'] = $this->alternateExchange->getName();
+            }
+            if($this->confirm !== null) {
+                $parameters['confirm'] = $this->confirm;
+            }
+            if($this->consumerCancelNotify !== null) {
+                $parameters['consumer_cancel_notify'] = $this->consumerCancelNotify;
+            }
+            if($this->deadLetterQueue !== null) {
+                $parameters['x-dead-letter-exchange'] = $this->deadLetterQueue->getName();
+            }
+            if($this->maxLength) {
+                $parameters['x-max-length'] = $this->maxLength;
+            }
+            if($this->maxPriority) {
+                $parameters['x-max-priority'] = $this->maxPriority;
+            }
+            if($this->ttl) {
+                $parameters['x-message-ttl'] = $this->ttl;
+            }
 			
-			if(!$parameters) {
-				$parameters = null;
-			}
-			$amqpChannel->queue_declare($this->name, $this->passive, $this->durable, $this->exclusive, $this->autoDelete, $this->noWait, $parameters);
+            if(!$parameters) {
+                $parameters = null;
+            }
+            $amqpChannel->queue_declare($this->name, $this->passive, $this->durable, $this->exclusive, $this->autoDelete, $this->noWait, $parameters);
 			
-			$this->init = true;
-		}
-	}
+            $this->init = true;
+        }
+    }
 
 
-	public function comsume() {
+    public function comsume() {
 	
-	}
+    }
 }
\ No newline at end of file

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);