as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2020-10-09 17:30:45 +08:00
parent 00ba75eb88
commit 542b6bed1e
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Broker.php
+4 -4
View File
@@ -186,10 +186,10 @@ class Broker
if ($host && $port) { if ($host && $port) {
try { try {
$socket = $this->getSocket($host, $port, $modeSync); $socket = $this->getSocket($host, $port, $modeSync);
if (!$modeSync) { // if (!$modeSync) {
$socket->SetonReadable($this->process); // $socket->SetonReadable($this->process);
} // }
$socket->connect(); // $socket->connect();
$this->{$type}[$key] = $socket; $this->{$type}[$key] = $socket;
return $socket; return $socket;
} catch (\Exception $e) { } catch (\Exception $e) {