如何使Laravel 5.4与AWS SQS队列一起使用

瑞安·威尔逊(Ryan Wilson)

我正在将Laravel 5.4与SQS Fifo队列一起使用。

我似乎无法使其与SQS Fifo Queue一起使用。排队我的电子邮件作业。

任何有此经验的人都可以向我指出如何使laravel与SQS Fifo Queue一起使用的正确方向。

这是我的控制器代码,用于将作业添加到队列中:

(new ReferFriendEmail($referFriendObj))->onConnection('my_sqs_fifo');

这是我的工作代码:

class ReferFriendEmail implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $referFriendObj = false;

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct($referFriendObj)
    {
        $this->referFriendObj = $referFriendObj;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle(  )
    {
        $input = $this->referFriendObj->input;

        Mail::send( 'emails.refer-a-friend', 
            [
                'user' => $this->referFriendObj->from_user_info,
                'first_name' => strtoupper( trim( $this->referFriendObj->from_user_info->first_name)),
                'unique_link' => $this->referFriendObj->unique_link,
            ],
            function ($m) use ( $input ) {
                    $m->from('[email protected]', 'Kuflink');
                    $m->to($input['to_email'], $input['to_email'] )->subject( "You've been referred to Kuflink by " . $input['first_name'] );
            }
        );

        Email_user_referrer::where('email' , $input['to_email'])
                            ->update(['flag_email_sent' => 1]);
    }
}

似乎一切都没有进展。我将其用作驱动程序。

塞贾约兹

根据评论,您正在创建作业,但实际上并没有发送它。dispatch助手可以实现这个要求

$job = (new ReferFriendEmail($referFriendObj))->onConnection('my_sqs_fif‌​o');
dispatch($job);

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

如何使Laravel与AWS上的Redis集群一起使用

与with()一起使用时的Laravel 5 BadMethodCallException

使Laravel 5与xampp for OSX一起使用

将OpenLayers 4与Angular 5一起使用

Laravel 队列在与哨兵一起使用时停顿

如何使用 AWS DynamoDB 和 AWS SQS 创建作业队列?

如何设置AWS集群以与openCPU一起使用?

如何使Zalenium与AWS Fargate一起使用?

了解div居中如何与bootstrap 4一起使用

如何在与工匠一起运行的laravel 5中包含CSS?

将Laravel 5方法注入与其他参数一起使用

Laravel 5-与重定向一起使用时withInput不起作用

将Laravel 5与XAMPP数据库一起使用

使T4MVC与ASP.NET 5一起使用

在4K屏幕上将Matplotlib与TKAgg或Qt5Agg后端一起使用

Laravel 5 搜索和分页网址一起

如何在自定义网络中将 JUnit 5 与测试容器一起使用?

Qt5:如何将QPointer与Forward Declared类一起使用

2022 年 5 月 30 日之后如何将 MailKit 与 Google 一起使用?

如何在.NET MVC Core 5中将WebMatrix方法与Npgsql一起使用

如何在 Ubuntu 中将 Docker 与 socks5 一起使用?

如何存根/模拟JDBC ResultSet以便与Java 5和6一起使用?

流星:如何转换HTML / HTML5代码以与流星一起使用?

如何将ShowCaseView v5生成器与片段一起使用?

如何使StructureMap与AngularJs / MVC5和WebApi2 Web项目一起使用

如何正确安装dc.js以与Rails 5一起使用?

如何将SSH与SOCKS 5代理一起使用?

我如何才能将Font Awesome 5与React一起使用?

如何使Angularjs路由与html5mode上的expressJs路由一起使用