thecodingmachine / oo-amqp-client

src/Client.php

Indentation +146 added lines, -146 removed lines

@@ -6,155 +6,155 @@
 
 class Client {
 	
-	/**
-	 * RabbitMq host
-	 * @var string
-	 */
-	private $host;
-	
-	/**
-	 * RabbitMq port
-	 * @var string
-	 */
-	private $port;
-	
-	/**
-	 * RabbitMq user
-	 * @var string
-	 */
-	private $user;
-	
-	/**
-	 * RabbitMq password
-	 * @var string
-	 */
-	private $password;
-	
-	/**
-	 * It's for QOS prefetch-size http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos
-	 * @var int
-	 */
-	private $prefetchSize = null;
-	
-	/**
-	 * It's for QOS prefetch-count http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos
-	 * @var int
-	 */
-	private $prefetchCount = null;
-	
-	/**
-	 * It's for QOS global http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos
-	 * @var int
-	 */
-	private $aGlobal = null;
-	
-	/**
-	 * RabbitMq connection
-	 * @var AMQPStreamConnection
-	 */
-	private $connection = null;
-	
-	/**
-	 * RabbitMq channel
-	 * @var \AMQPChannel
-	 */
-	private $channel = null;
-	
-	/**
-	 * List of RabbitMq object
-	 * @var RabbitMqObjectInterface
-	 */
-	private $rabbitMqObjects = [];
-	
-	public function __construct($host, $port, $user, $password) {
-		$this->host = $host;
-		$this->port = ($port !== null) ? $port : 5672;
-		$this->user = $user;
-		$this->password = $password;
-	}
+    /**
+     * RabbitMq host
+     * @var string
+     */
+    private $host;
+	
+    /**
+     * RabbitMq port
+     * @var string
+     */
+    private $port;
+	
+    /**
+     * RabbitMq user
+     * @var string
+     */
+    private $user;
+	
+    /**
+     * RabbitMq password
+     * @var string
+     */
+    private $password;
+	
+    /**
+     * It's for QOS prefetch-size http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos
+     * @var int
+     */
+    private $prefetchSize = null;
+	
+    /**
+     * It's for QOS prefetch-count http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos
+     * @var int
+     */
+    private $prefetchCount = null;
+	
+    /**
+     * It's for QOS global http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos
+     * @var int
+     */
+    private $aGlobal = null;
+	
+    /**
+     * RabbitMq connection
+     * @var AMQPStreamConnection
+     */
+    private $connection = null;
+	
+    /**
+     * RabbitMq channel
+     * @var \AMQPChannel
+     */
+    private $channel = null;
+	
+    /**
+     * List of RabbitMq object
+     * @var RabbitMqObjectInterface
+     */
+    private $rabbitMqObjects = [];
+	
+    public function __construct($host, $port, $user, $password) {
+        $this->host = $host;
+        $this->port = ($port !== null) ? $port : 5672;
+        $this->user = $user;
+        $this->password = $password;
+    }
 
-	/**
-	 * Get prefetch size for QOS
-	 */
-	public function getPrefetchSize() {
-		return $this->prefetchSize;
-	}
-	
-	/**
-	 * Set prefetch size
-	 * It's for QOS prefetch-size http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos
-	 * 
-	 * @param int $prefetchSize
-	 */
-	public function setPrefetchSize($prefetchSize) {
-		$this->prefetchSize = $prefetchSize;
-		return $this;
-	}
-	
-	/**
-	 * Get prefetch count for QOS
-	 */
-	public function getPrefetchCount() {
-		return $this->prefetchCount;
-	}
-	
-	/**
-	 * Set prefetch size
-	 * It's for QOS prefetch-size http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos
-	 * 
-	 * @param int $prefetchCount
-	 */
-	public function setPrefetchCount($prefetchCount) {
-		$this->prefetchCount = $prefetchCount;
-		return $this;
-	}
-	
-	/**
-	 * Get a global for QOS
-	 */
-	public function getAGlobal() {
-		return $this->aGlobal;
-	}
-	
-	/**
-	 * Set global
-	 * It's for QOS prefetch-size http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos
-	 * 
-	 * @param int $aGlobal
-	 */
-	public function setAGlobal($aGlobal) {
-		$this->aGlobal = $aGlobal;
-		return $this;
-	}
-	
-	/**
-	 * Set RabbitMq object
-	 * @param RabbitMqObjectInterface[] $rabbitMqObjects
-	 */
-	public function setRabbitMqObjects(array $rabbitMqObjects) {
-		$this->rabbitMqObjects = $rabbitMqObjects;
-	}
-	
-	/**
-	 * Connection to the RabbitMq service with AMQPStreamConnection
-	 *
-	 * @return AMQPChannel
-	 */
-	public function getChannel() {
-		if(!$this->connection) {
-			$this->connection = new AMQPStreamConnection($this->host, $this->port, $this->user, $this->password);
+    /**
+     * Get prefetch size for QOS
+     */
+    public function getPrefetchSize() {
+        return $this->prefetchSize;
+    }
+	
+    /**
+     * Set prefetch size
+     * It's for QOS prefetch-size http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos
+     * 
+     * @param int $prefetchSize
+     */
+    public function setPrefetchSize($prefetchSize) {
+        $this->prefetchSize = $prefetchSize;
+        return $this;
+    }
+	
+    /**
+     * Get prefetch count for QOS
+     */
+    public function getPrefetchCount() {
+        return $this->prefetchCount;
+    }
+	
+    /**
+     * Set prefetch size
+     * It's for QOS prefetch-size http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos
+     * 
+     * @param int $prefetchCount
+     */
+    public function setPrefetchCount($prefetchCount) {
+        $this->prefetchCount = $prefetchCount;
+        return $this;
+    }
+	
+    /**
+     * Get a global for QOS
+     */
+    public function getAGlobal() {
+        return $this->aGlobal;
+    }
+	
+    /**
+     * Set global
+     * It's for QOS prefetch-size http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos
+     * 
+     * @param int $aGlobal
+     */
+    public function setAGlobal($aGlobal) {
+        $this->aGlobal = $aGlobal;
+        return $this;
+    }
+	
+    /**
+     * Set RabbitMq object
+     * @param RabbitMqObjectInterface[] $rabbitMqObjects
+     */
+    public function setRabbitMqObjects(array $rabbitMqObjects) {
+        $this->rabbitMqObjects = $rabbitMqObjects;
+    }
+	
+    /**
+     * Connection to the RabbitMq service with AMQPStreamConnection
+     *
+     * @return AMQPChannel
+     */
+    public function getChannel() {
+        if(!$this->connection) {
+            $this->connection = new AMQPStreamConnection($this->host, $this->port, $this->user, $this->password);
 
-			$this->channel = $this->connection->channel();
+            $this->channel = $this->connection->channel();
 			
- 			if($this->prefetchCount !== null || $this->prefetchCount !== null || $this->aGlobal !== null) {
-				$this->channel->basic_qos(null, 1, null);
- 			}
+                if($this->prefetchCount !== null || $this->prefetchCount !== null || $this->aGlobal !== null) {
+                $this->channel->basic_qos(null, 1, null);
+                }
 			
-			foreach ($this->rabbitMqObjects as $rabbitMqObject) {
-				$rabbitMqObject->init($this->channel);
-			}
-		}
-		return $this->channel;
-	}
+            foreach ($this->rabbitMqObjects as $rabbitMqObject) {
+                $rabbitMqObject->init($this->channel);
+            }
+        }
+        return $this->channel;
+    }
 	
 }
\ No newline at end of file

src/Objects/Exchange.php

Indentation +224 added lines, -224 removed lines

@@ -8,238 +8,238 @@
 
 class Exchange implements RabbitMqObjectInterface{
 
-	/**
-	 * @var Client
-	 */
-	private $client;
+    /**
+     * @var Client
+     */
+    private $client;
 
-	/**
-	 * Name
-	 * @var string
-	 */
-	private $name;
-	
-	/**
-	 * Type direct, topic, headers or fanout
-	 * @var string
-	 */
-	private $type;
-	
-	/**
-	 * Passive
-	 * @var bool
-	 */
-	private $passive = false;
-	
-	/**
-	 * Durable
-	 * @var bool
-	 */
-	private $durable = false;
-	
-	/**
-	 * Auto delete
-	 * @var bool
-	 */
-	private $autoDelete = false;
-	
-	/**
-	 * Internal
-	 * @var bool
-	 */
-	private $internal = falsel;
-	
-	/**
-	 * No wait
-	 * @var bool
-	 */
-	private $nowait = false;
-	
-	/**
-	 * Arguments
-	 * @var array
-	 */
-	private $arguments = null;
-	
-	/**
-	 * Ticket
-	 * @var int
-	 */
-	private $ticket = null;
-	
-	/**
-	 * Parameter to initialize object only one time
-	 * @var bool
-	 */
-	private $init = false;
-	
-	/**
-	 * Set the to (Binding)
-	 * @param Binding $to
-	 * @param string $name
-	 * @param string $type direct, topic, headers or fanout
-	 */
-	public function __construct(Client $client, $name, $type) {
-		$this->client = $client;
-		$this->name = $name;
-		$this->type = $type;
-	}
+    /**
+     * Name
+     * @var string
+     */
+    private $name;
+	
+    /**
+     * Type direct, topic, headers or fanout
+     * @var string
+     */
+    private $type;
+	
+    /**
+     * Passive
+     * @var bool
+     */
+    private $passive = false;
+	
+    /**
+     * Durable
+     * @var bool
+     */
+    private $durable = false;
+	
+    /**
+     * Auto delete
+     * @var bool
+     */
+    private $autoDelete = false;
+	
+    /**
+     * Internal
+     * @var bool
+     */
+    private $internal = falsel;
+	
+    /**
+     * No wait
+     * @var bool
+     */
+    private $nowait = false;
+	
+    /**
+     * Arguments
+     * @var array
+     */
+    private $arguments = null;
+	
+    /**
+     * Ticket
+     * @var int
+     */
+    private $ticket = null;
+	
+    /**
+     * Parameter to initialize object only one time
+     * @var bool
+     */
+    private $init = false;
+	
+    /**
+     * Set the to (Binding)
+     * @param Binding $to
+     * @param string $name
+     * @param string $type direct, topic, headers or fanout
+     */
+    public function __construct(Client $client, $name, $type) {
+        $this->client = $client;
+        $this->name = $name;
+        $this->type = $type;
+    }
 
-	/**
-	 * Get the exchange name
-	 * @return string
-	 */
-	public function getName() {
-		return $this->name;
-	}
-	
-	/**
-	 * Get passive
-	 * @return bool
-	 */
-	public function getPassive() {
-		return $this->passive;
-	}
-	
-	/**
-	 * Set passive
-	 * @param bool $passive
-	 * @return Exchange
-	 */
-	public function setPassive($passive) {
-		$this->passive = $passive;
-		return $this;
-	}
+    /**
+     * Get the exchange name
+     * @return string
+     */
+    public function getName() {
+        return $this->name;
+    }
+	
+    /**
+     * Get passive
+     * @return bool
+     */
+    public function getPassive() {
+        return $this->passive;
+    }
+	
+    /**
+     * Set passive
+     * @param bool $passive
+     * @return Exchange
+     */
+    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 Exchange
-	 */
-	public function setDurable($durable) {
-		$this->durable = $durable;
-		return $this;
-	}
+    /**
+     * Get durable
+     * @return bool
+     */
+    public function getDurable() {
+        return $this->durable;
+    }
+	
+    /**
+     * Set durable
+     * @param bool $durable
+     * @return Exchange
+     */
+    public function setDurable($durable) {
+        $this->durable = $durable;
+        return $this;
+    }
 
-	/**
-	 * Get autoDelete
-	 * @return bool
-	 */
-	public function getAutoDelete() {
-		return $this->autoDelete;
-	}
-	
-	/**
-	 * Set autoDelete
-	 * @param bool $autoDelete
-	 * @return Exchange
-	 */
-	public function setAutoDelete($autoDelete) {
-		$this->autoDelete = $autoDelete;
-		return $this;
-	}
+    /**
+     * Get autoDelete
+     * @return bool
+     */
+    public function getAutoDelete() {
+        return $this->autoDelete;
+    }
+	
+    /**
+     * Set autoDelete
+     * @param bool $autoDelete
+     * @return Exchange
+     */
+    public function setAutoDelete($autoDelete) {
+        $this->autoDelete = $autoDelete;
+        return $this;
+    }
 
-	/**
-	 * Get internal
-	 * @return bool
-	 */
-	public function getInternal() {
-		return $this->internal;
-	}
-	
-	/**
-	 * Set internal
-	 * @param bool $internal
-	 * @return Exchange
-	 */
-	public function setInternal($internal) {
-		$this->internal = $internal;
-		return $this;
-	}
+    /**
+     * Get internal
+     * @return bool
+     */
+    public function getInternal() {
+        return $this->internal;
+    }
+	
+    /**
+     * Set internal
+     * @param bool $internal
+     * @return Exchange
+     */
+    public function setInternal($internal) {
+        $this->internal = $internal;
+        return $this;
+    }
 
-	/**
-	 * Get nowait
-	 * @return bool
-	 */
-	public function getNowait() {
-		return $this->nowait;
-	}
-	
-	/**
-	 * Set nowait
-	 * @param bool $nowait
-	 * @return Exchange
-	 */
-	public function setNowait($nowait) {
-		$this->nowait = $nowait;
-		return $this;
-	}
+    /**
+     * Get nowait
+     * @return bool
+     */
+    public function getNowait() {
+        return $this->nowait;
+    }
+	
+    /**
+     * Set nowait
+     * @param bool $nowait
+     * @return Exchange
+     */
+    public function setNowait($nowait) {
+        $this->nowait = $nowait;
+        return $this;
+    }
 
-	/**
-	 * Get arguments
-	 * @return array
-	 */
-	public function getArguments() {
-		return $this->arguments;
-	}
-	
-	/**
-	 * Set arguments
-	 * @param array $arguments
-	 * @return Exchange
-	 */
-	public function setArguments($arguments) {
-		$this->arguments = $arguments;
-		return $this;
-	}
+    /**
+     * Get arguments
+     * @return array
+     */
+    public function getArguments() {
+        return $this->arguments;
+    }
+	
+    /**
+     * Set arguments
+     * @param array $arguments
+     * @return Exchange
+     */
+    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 Exchange
-	 */
-	public function setTicket($ticket) {
-		$this->ticket = $ticket;
-		return $this;
-	}
-	
-	public function init(AMQPChannel $amqpChannel) {
-		if(!$this->init) {
-			$amqpChannel->exchange_declare($this->name,
-											$this->type,
-											$this->passive,
-									        $this->durable,
-									        $this->auto_delete,
-									        $this->internal,
-									        $this->nowait,
-									        $this->arguments,
-									        $this->ticket);
-			$this->init = true;
-		}
-	}
-	
-	public function publish(AMQPMessage $message, $routingKey, $mandatory = false,
-							$immediate = false,
-							$ticket = null) {
-		$channel = $this->client->getChannel();
+    /**
+     * Get ticket
+     * @return int
+     */
+    public function getTicket() {
+        return $this->ticket;
+    }
+	
+    /**
+     * Set ticket
+     * @param int $ticket
+     * @return Exchange
+     */
+    public function setTicket($ticket) {
+        $this->ticket = $ticket;
+        return $this;
+    }
+	
+    public function init(AMQPChannel $amqpChannel) {
+        if(!$this->init) {
+            $amqpChannel->exchange_declare($this->name,
+                                            $this->type,
+                                            $this->passive,
+                                            $this->durable,
+                                            $this->auto_delete,
+                                            $this->internal,
+                                            $this->nowait,
+                                            $this->arguments,
+                                            $this->ticket);
+            $this->init = true;
+        }
+    }
+	
+    public function publish(AMQPMessage $message, $routingKey, $mandatory = false,
+                            $immediate = false,
+                            $ticket = null) {
+        $channel = $this->client->getChannel();
 
-		$channel->basic_publish($message, $this->name, $routingKey, $mandatory, $immediate, $ticket);
-	}
+        $channel->basic_publish($message, $this->name, $routingKey, $mandatory, $immediate, $ticket);
+    }
 	
 }
\ No newline at end of file