thecodingmachine / oo-amqp-client

src/Client.php

Spacing +2 added lines, -2 removed lines

@@ -141,12 +141,12 @@
 	 * @return AMQPChannel
 	 */
 	public function getChannel() {
-		if(!$this->connection) {
+		if (!$this->connection) {
 			$this->connection = new AMQPStreamConnection($this->host, $this->port, $this->user, $this->password);
 
 			$this->channel = $this->connection->channel();
 			
- 			if($this->prefetchCount !== null || $this->prefetchCount !== null || $this->aGlobal !== null) {
+ 			if ($this->prefetchCount !== null || $this->prefetchCount !== null || $this->aGlobal !== null) {
 				$this->channel->basic_qos(null, 1, null);
  			}
 			

src/Objects/Exchange.php

Spacing +2 added lines, -2 removed lines

@@ -6,7 +6,7 @@ 
 use PhpAmqpLib\Channel\AMQPChannel;
 use PhpAmqpLib\Message\AMQPMessage;
 
-class Exchange implements RabbitMqObjectInterface{
+class Exchange implements RabbitMqObjectInterface {
 
 	/**
 	 * @var Client
@@ -220,7 +220,7 @@ 
 	}
 	
 	public function init(AMQPChannel $amqpChannel) {
-		if(!$this->init) {
+		if (!$this->init) {
 			$amqpChannel->exchange_declare($this->name,
 											$this->type,
 											$this->passive,