改名

2020-10-30 11:54:07 +08:00
parent 625f6c7b07
commit 255afa188e
1 changed files with 3 additions and 0 deletions
@@ -96,6 +96,9 @@ class Producer extends Component

 		$this->setTopicAcks($isAck);
 		$this->push($message, $key);
+		if ($isAck) {
+			$this->flush();
+		}
 	}