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

modify

Browse Source
This commit is contained in:
as2252258@163.com
2021-04-11 18:11:49 +08:00
parent d12b1c36c6
commit 5b0467944b
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/TaskContainer.php
+1
View File
@@ -53,6 +53,7 @@ class TaskContainer extends BaseObject
public function process($topic, Struct $struct) public function process($topic, Struct $struct)
{ {
$handler = $this->_topics[$topic] ?? null; $handler = $this->_topics[$topic] ?? null;
var_dump($handler, $struct);
if (empty($handler)) { if (empty($handler)) {
return; return;
} }