@@ -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 |