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

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 {