data cache in horizon

Hi all, I have a horizon worker that execute a notification job. I need to make the mailer params dynamically loaded from my data. I tried to

config()->set(['mail.mailers.smtp.host' => ...])

but If the horizon worker is running, it does not load the changes.

I tried setting the Symfony transport:

$factory = new EsmtpTransportFactory;
        $transport = $factory->create(new Dsn($params['scheme'], $params['host'], $params['username'], $params['password'], $params['port']));
        app('mailer')->setSymfonyTransport($transport);

But got no better results. I'm sure I intercept when my job needs to send with different params, but could not get it work unless I stop and restart the horizon worker.

Any idea?

Thanks in advance.

LaryAI

1 year ago

Level 58

To dynamically change the mailer configuration for a job running in Laravel Horizon, you need to ensure that the changes are applied at runtime, as the configuration is typically cached when the worker starts. Here's a solution that should work:

Use a Custom Mailer Configuration: Instead of trying to modify the global mail configuration, create a custom mailer configuration within your job. This way, you can set the parameters dynamically each time the job runs.
Set Up a Custom Transport: You can create a custom transport for the mailer within your job. This involves creating a new instance of the mailer with the desired configuration.

Here's how you can implement this:

use Illuminate\Mail\MailManager;
use Symfony\Component\Mailer\Transport\Dsn;
use Symfony\Component\Mailer\Transport\Smtp\EsmtpTransportFactory;

public function handle()
{
    // Define your dynamic mailer parameters
    $params = [
        'scheme' => 'smtp',
        'host' => 'your-dynamic-host',
        'username' => 'your-dynamic-username',
        'password' => 'your-dynamic-password',
        'port' => 587,
    ];

    // Create a new transport using the dynamic parameters
    $factory = new EsmtpTransportFactory();
    $transport = $factory->create(new Dsn(
        $params['scheme'],
        $params['host'],
        $params['username'],
        $params['password'],
        $params['port']
    ));

    // Get the mail manager instance
    $mailManager = app(MailManager::class);

    // Create a new mailer instance with the custom transport
    $mailer = $mailManager->mailer('smtp');
    $mailer->setSymfonyTransport($transport);

    // Use the custom mailer to send your email
    $mailer->to('[email protected]')->send(new YourMailable());
}

Key Points:

Custom Transport: By creating a custom transport, you ensure that each job execution uses the latest configuration.
Mailer Instance: You create a new mailer instance with the custom transport, which allows you to send emails with the updated configuration.
Avoid Global Config Changes: This approach avoids changing the global configuration, which is beneficial in a multi-worker environment like Horizon.

This solution should allow you to dynamically change the mailer configuration without needing to restart your Horizon workers.