|
@@ -81,7 +81,9 @@ class ContentFeedCreate extends Command
|
|
|
|
|
|
$callback = function ($msg) {
|
|
|
$param = \GuzzleHttp\json_decode($msg->body,true);
|
|
|
+ $this->line('收到消息'.$msg->body);
|
|
|
$row = $this->feedRepositories->feedCreate($param);
|
|
|
+ $this->line('处理消息'.$row);
|
|
|
if($row){
|
|
|
$msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
|
|
|
}
|