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-28 11:55:30 +08:00
parent 3256c331d4
commit c84fcda10b
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Kafka.php
+3 -2
View File
@@ -89,11 +89,12 @@ class Kafka extends \Snowflake\Process\Process
/** /**
* @param ConsumerTopic $topic * @param ConsumerTopic $topic
* @param $interval
*/ */
private function resolve(ConsumerTopic $topic, $intval) private function resolve(ConsumerTopic $topic, $interval)
{ {
try { try {
$message = $topic->consume(0, $intval); $message = $topic->consume(0, $interval);
if (empty($message)) { if (empty($message)) {
$this->application->debug('message null.'); $this->application->debug('message null.');
return; return;