@@ -17,12 +17,9 @@ |
||
17 | 17 | namespace IPub\WebSocketsZMQ\Pusher; |
18 | 18 | |
19 | 19 | use Psr\Log; |
20 | - |
|
21 | 20 | use IPub; |
22 | 21 | use IPub\WebSocketsZMQ; |
23 | - |
|
24 | 22 | use IPub\WebSockets\Router; |
25 | - |
|
26 | 23 | use IPub\WebSocketsWAMP\PushMessages; |
27 | 24 | use IPub\WebSocketsWAMP\Serializers; |
28 | 25 |
@@ -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 @@ 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 { |
@@ -17,21 +17,15 @@ |
||
17 | 17 | namespace IPub\WebSocketsZMQ\Consumer; |
18 | 18 | |
19 | 19 | use Closure; |
20 | - |
|
21 | 20 | use Psr\Log; |
22 | - |
|
23 | -use React; |
|
24 | 21 | use React\EventLoop; |
25 | 22 | use React\ZMQ; |
26 | - |
|
27 | 23 | use IPub; |
28 | 24 | use IPub\WebSocketsZMQ; |
29 | - |
|
30 | 25 | use IPub\WebSocketsWAMP\Application; |
31 | 26 | use IPub\WebSocketsWAMP\Entities; |
32 | 27 | use IPub\WebSocketsWAMP\PushMessages; |
33 | 28 | use IPub\WebSocketsWAMP\Serializers; |
34 | - |
|
35 | 29 | use IPub\WebSockets\Exceptions as WebSocketsExceptions; |
36 | 30 | |
37 | 31 | /** |
@@ -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 @@ |
||
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 |