|
@@ -12,7 +12,7 @@ discard block |
|
|
block discarded – undo |
|
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
|
|
|
@@ -86,7 +86,7 @@ discard block |
|
|
block discarded – undo |
|
86
|
86
|
return; |
|
87
|
87
|
} |
|
88
|
88
|
|
|
89
|
|
- $this->socket->disconnect($this->configuration->getHost() . ':' . $this->configuration->getPort()); |
|
|
89
|
+ $this->socket->disconnect($this->configuration->getHost().':'.$this->configuration->getPort()); |
|
90
|
90
|
} |
|
91
|
91
|
|
|
92
|
92
|
/** |
|
@@ -108,7 +108,7 @@ discard block |
|
|
block discarded – undo |
|
108
|
108
|
$context = new ZMQContext(1, $this->configuration->isPersistent()); |
|
109
|
109
|
|
|
110
|
110
|
$this->socket = new ZMQSocket($context, ZMQ::SOCKET_PUSH); |
|
111
|
|
- $this->socket->connect($this->configuration->getProtocol() . '://' . $this->configuration->getHost() . ':' . $this->configuration->getPort()); |
|
|
111
|
+ $this->socket->connect($this->configuration->getProtocol().'://'.$this->configuration->getHost().':'.$this->configuration->getPort()); |
|
112
|
112
|
|
|
113
|
113
|
$this->setConnected(); |
|
114
|
114
|
} |
Please login to merge, or discard this patch.