modify

2021-03-26 01:18:11 +08:00
parent be9d782d02
commit 3eafeb52ed
1 changed files with 1 additions and 1 deletions
@@ -33,7 +33,7 @@ class Kafka extends \Snowflake\Process\Process
 	 */
 	public function onHandler(Process $process): void
 	{
-		$this->waite(json_decode($process->read(), true));
+		$this->waite(swoole_unserialize($process->read()));
 	}