<?php namespace App\Http\Controllers; use Illuminate\Http\Request; use App\Http\Models\WechatTemplateSendInfo; use App\Http\Requests; use App\Jobs\QueuedTest; class QueuedController extends Controller { public function Test(){ $data = WechatTemplateSendInfo::get_wechat_template_send_info(1); $send_data=array( 'send_time'=>date("Y-m-d H:i:s"), 'data' => $data ); // $data=array( // 'time'=>time() // ); $job = (new QueuedTest($send_data))->onConnection('rabbitmq')->onQueue('laravel_queue'); dispatch($job); } }