huahuibao/common/components/rabbitmq/importDataConsumer.php

<?php
/**
 * Created by PhpStorm.
 * User: ssh <ssh@zhhinc.com>
 * Date: 2019/9/9 0009
 * Time: 14:54
 */

namespace common\components\rabbitmq;

use mikemadisonweb\rabbitmq\components\ConsumerInterface;
use PhpAmqpLib\Message\AMQPMessage;

class importDataConsumer implements ConsumerInterface
{

	/**
	 * 消费队列
	 * @param AMQPMessage $msg
	 * @return bool
	 */
	public function execute(AMQPMessage $msg)
	{
		$data = unserialize($msg->body);
		print_r($data);
        print_r('ImportDataConsumer done! ');

		//有什么东西可以放到队列里去
		//微信模板消息
		//新商家注册后的开店流程

		return ConsumerInterface::MSG_ACK;
	}

}