QueuedController.php 691 B

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