thecodingmachine / oo-amqp-client

src/Objects/Binding.php

Unused Use Statements -1 removed lines

@@ -2,7 +2,6 @@
 namespace Mouf\AmqpClient\Objects;
 
 use Mouf\AmqpClient\RabbitMqObjectInterface;
-use PhpAmqpLib\Connection\AMQPStreamConnection;
 use PhpAmqpLib\Channel\AMQPChannel;
 
 class Binding implements RabbitMqObjectInterface{

Spacing +2 added lines, -2 removed lines

@@ -5,7 +5,7 @@ 
 use PhpAmqpLib\Connection\AMQPStreamConnection;
 use PhpAmqpLib\Channel\AMQPChannel;
 
-class Binding implements RabbitMqObjectInterface{
+class Binding implements RabbitMqObjectInterface {
 	
 	/**
 	 * 
@@ -60,7 +60,7 @@ 
 	}
 	
 	public function init(AMQPChannel $amqpChannel) {
-		if(!$this->init) {
+		if (!$this->init) {
 			$this->source->init();
 			$this->to->init();
 			

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/Queue.php

Spacing +2 added lines, -2 removed lines

@@ -8,7 +8,7 @@ 
  * @author Marc
  *
  */
-class Queue implements RabbitMqObjectInterface{
+class Queue implements RabbitMqObjectInterface {
 
 	/**
 	 * 
@@ -221,7 +221,7 @@ 
 	
 	
 	public function init(AMQPChannel $amqpChannel) {
-		if(!$this->init) {
+		if (!$this->init) {
 			$this->source->init($amqpChannel);
 			$this->deadLetterQueue->init($amqpChannel);
 			//TODO wip

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,