QueuedController.php 605 B

12345678910111213141516171819202122232425
  1. <?php
  2. namespace App\Http\Controllers;
  3. use Illuminate\Http\Request;
  4. use App\Http\Models\WechatTemplateSendInfo;
  5. use App\Http\Requests;
  6. use App\Jobs\QueuedTest;
  7. class QueuedController extends Controller
  8. {
  9. public function Test(){
  10. $data = WechatTemplateSendInfo::get_wechat_template_send_info(1);
  11. $send_data=array(
  12. 'send_time'=>date("Y-m-d H:i:s"),
  13. 'data' => $data
  14. );
  15. // $data=array(
  16. // 'time'=>time()
  17. // );
  18. $job = (new QueuedTest($send_data))->onConnection('rabbitmq')->onQueue('laravel_queue');
  19. dispatch($job);
  20. }
  21. }