iPublikuj / websockets-zmq

src/IPub/WebSocketsZMQ/Pusher/Pusher.php

Spacing +2 added lines, -2 removed lines

@@ -78,7 +78,7 @@ 
 			return;
 		}
 
-		$this->socket->disconnect($this->configuration->getHost() . ':' . $this->configuration->getPort());
+		$this->socket->disconnect($this->configuration->getHost().':'.$this->configuration->getPort());
 	}
 
 	/**
@@ -98,7 +98,7 @@ 
 			$context = new \ZMQContext(1, $this->configuration->isPersistent());
 
 			$this->socket = new \ZMQSocket($context, \ZMQ::SOCKET_PUSH);
-			$this->socket->connect($this->configuration->getProtocol() . '://' . $this->configuration->getHost() . ':' . $this->configuration->getPort());
+			$this->socket->connect($this->configuration->getProtocol().'://'.$this->configuration->getHost().':'.$this->configuration->getPort());
 
 			$this->setConnected();
 		}

Unused Use Statements -3 removed lines

@@ -17,12 +17,9 @@
 namespace IPub\WebSocketsZMQ\Pusher;
 
 use Psr\Log;
-
 use IPub;
 use IPub\WebSocketsZMQ;
-
 use IPub\WebSockets\Router;
-
 use IPub\WebSocketsWAMP\PushMessages;
 use IPub\WebSocketsWAMP\Serializers;
 

src/IPub/WebSocketsZMQ/Consumer/Consumer.php

Spacing +1 added lines, -1 removed lines

@@ -92,7 +92,7 @@
 			$this->configuration->getPort()
 		));
 
-		$this->socket->bind($this->configuration->getProtocol() . '://' . $this->configuration->getHost() . ':' . $this->configuration->getPort());
+		$this->socket->bind($this->configuration->getProtocol().'://'.$this->configuration->getHost().':'.$this->configuration->getPort());
 
 		$this->socket->on('message', function ($data) use ($application) {
 			try {

Unused Use Statements -4 removed lines

@@ -17,14 +17,10 @@
 namespace IPub\WebSocketsZMQ\Consumer;
 
 use Psr\Log;
-
-use React;
 use React\EventLoop;
 use React\ZMQ;
-
 use IPub;
 use IPub\WebSocketsZMQ;
-
 use IPub\WebSocketsWAMP\Application;
 use IPub\WebSocketsWAMP\Entities;
 use IPub\WebSocketsWAMP\PushMessages;