www.gusucode.com > ecShop PHP网上商城系统 粉丝修复版 v2.7.3源码程序 > ecshop_xf_v2.7.3/includes/prism-php/examples/mq_pub.php

    <?php
require('include.php');

$mq = $c->notify();

$i=0;
while(1){
    $mq->pub("order.new", 'message hello world: '. $i++);
    echo "send $i \n";
}