@@ -18,7 +18,6 @@ |
||
| 18 | 18 | |
| 19 | 19 | use Nette; |
| 20 | 20 | use Nette\DI; |
| 21 | - |
|
| 22 | 21 | use IPub; |
| 23 | 22 | use IPub\WebSocketsZMQ; |
| 24 | 23 | use IPub\WebSocketsZMQ\Consumer; |
@@ -12,7 +12,7 @@ |
||
| 12 | 12 | * @date 01.03.17 |
| 13 | 13 | */ |
| 14 | 14 | |
| 15 | -declare(strict_types = 1); |
|
| 15 | +declare(strict_types=1); |
|
| 16 | 16 | |
| 17 | 17 | namespace IPub\WebSocketsZMQ\DI; |
| 18 | 18 | |
@@ -12,7 +12,7 @@ discard block |
||
| 12 | 12 | * @date 28.02.17 |
| 13 | 13 | */ |
| 14 | 14 | |
| 15 | -declare(strict_types = 1); |
|
| 15 | +declare(strict_types=1); |
|
| 16 | 16 | |
| 17 | 17 | namespace IPub\WebSocketsZMQ\Consumer; |
| 18 | 18 | |
@@ -92,7 +92,7 @@ discard block |
||
| 92 | 92 | $this->configuration->getPort() |
| 93 | 93 | )); |
| 94 | 94 | |
| 95 | - $this->socket->bind($this->configuration->getProtocol() . '://' . $this->configuration->getHost() . ':' . $this->configuration->getPort()); |
|
| 95 | + $this->socket->bind($this->configuration->getProtocol().'://'.$this->configuration->getHost().':'.$this->configuration->getPort()); |
|
| 96 | 96 | |
| 97 | 97 | $this->socket->on('message', function ($data) use ($application) { |
| 98 | 98 | try { |
@@ -12,7 +12,7 @@ discard block |
||
| 12 | 12 | * @date 01.03.17 |
| 13 | 13 | */ |
| 14 | 14 | |
| 15 | -declare(strict_types = 1); |
|
| 15 | +declare(strict_types=1); |
|
| 16 | 16 | |
| 17 | 17 | namespace IPub\WebSocketsZMQ\Pusher; |
| 18 | 18 | |
@@ -78,7 +78,7 @@ discard block |
||
| 78 | 78 | return; |
| 79 | 79 | } |
| 80 | 80 | |
| 81 | - $this->socket->disconnect($this->configuration->getHost() . ':' . $this->configuration->getPort()); |
|
| 81 | + $this->socket->disconnect($this->configuration->getHost().':'.$this->configuration->getPort()); |
|
| 82 | 82 | } |
| 83 | 83 | |
| 84 | 84 | /** |
@@ -98,7 +98,7 @@ discard block |
||
| 98 | 98 | $context = new \ZMQContext(1, $this->configuration->isPersistent()); |
| 99 | 99 | |
| 100 | 100 | $this->socket = new \ZMQSocket($context, \ZMQ::SOCKET_PUSH); |
| 101 | - $this->socket->connect($this->configuration->getProtocol() . '://' . $this->configuration->getHost() . ':' . $this->configuration->getPort()); |
|
| 101 | + $this->socket->connect($this->configuration->getProtocol().'://'.$this->configuration->getHost().':'.$this->configuration->getPort()); |
|
| 102 | 102 | |
| 103 | 103 | $this->setConnected(); |
| 104 | 104 | } |
@@ -12,7 +12,7 @@ |
||
| 12 | 12 | * @date 28.02.17 |
| 13 | 13 | */ |
| 14 | 14 | |
| 15 | -declare(strict_types = 1); |
|
| 15 | +declare(strict_types=1); |
|
| 16 | 16 | |
| 17 | 17 | namespace IPub\WebSocketsZMQ; |
| 18 | 18 | |