支持列表

生产发布

boa::mq()->publish('boaPHP is so easy');

消费订阅

$mq = boa::mq();
$mq->subscribe();
while($mq->obj()->has()){
	$body = $mq->read();
	$head = $mq->obj()->head();
	$mq->ack();

	echo($body);
	ob_flush();
}
$mq->unsubscribe();