xyzshop/crontab/control/testpush.php

<?php
/**
 * Created by PhpStorm.
 * User: zry
 * Date: 2016/5/9
 * Time: 12:55
 */
defined('InShopNC') or exit('Access Invalid!');
ini_set('default_socket_timeout', -1);

class testpushControl extends BaseCronControl
{

    public function indexOp() {
        if (ob_get_level()) ob_end_clean();

        $param = array(
            'member_id'=>'36489',
            'text'     =>'Helloworld',
            'go_type'  =>'bonus',
        );

        QueueClient::push('upushSendMsg',$param);

    }
}