PHPackages lostlink/laravel-messenger - PHPackages - PHPackages [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register) 1. [Directory](/) 2. / 3. lostlink/laravel-messenger ActiveLibrary lostlink/laravel-messenger ========================== Send Messages to an Ingestor 2.1.4(1y ago)05.6kPHPPHP ^8.0||^8.1||^8.2||^8.3 Since Jul 9Pushed 1y ago1 watchersCompare [ Source](https://github.com/lostlink/laravel-messenger)[ Packagist](https://packagist.org/packages/lostlink/laravel-messenger)[ Docs](https://github.com/lostlink/messenger)[ RSS](/packages/lostlink-laravel-messenger/feed)WikiDiscussions main Synced 1mo ago READMEChangelog (8)Dependencies (5)Versions (9)Used By (0) LostLink Laravel-Messenger ========================== [](#lostlink-laravel-messenger) `LostLink Laravel-Messenger` is a Laravel package for sending messages to various services asynchronously without blocking the processing of your application. Messages are queued and sent during the PHP `destruct()` phase, ensuring that the application’s performance is not impacted by external service communication. Features -------- [](#features) - **Non-blocking message dispatch**: Messages are processed after the PHP request lifecycle. - **Extensible driver system**: Add custom drivers to send messages to services of your choice. - **Simple configuration**: Set up different drivers with environment variables. - **Rate limiting**: Control the rate at which messages are sent to avoid exceeding service limits. ### Supported Drivers [](#supported-drivers) - [Log](https://laravel.com/docs/logging/) - [Amazon Kinesis](https://aws.amazon.com/kinesis/) - [Tinybird](https://www.tinybird.co/) Installation ------------ [](#installation) 1. Install the package via Composer: ``` composer require lostlink/laravel-messenger ``` 2. Publish the configuration file (optional): ``` php artisan vendor:publish --tag=messenger-config ``` 3. Configure the environment variables for the drivers you wish to use. Configuration ------------- [](#configuration) The package supports multiple drivers, and you can set the default driver using environment variables. Here’s an example configuration file: ``` return [ 'default' => env('LARAVEL_MESSENGER_DRIVER', 'log'), 'drivers' => [ 'log' => [ 'class' => Lostlink\Messenger\Drivers\Log::class, 'rate_limit' => [ 'enabled' => env('LARAVEL_MESSENGER_LOG_RATE_LIMIT_ENABLED', false), 'max_attempts' => env('LARAVEL_MESSENGER_LOG_RATE_LIMIT_MAX_ATTEMPTS', 10), 'decay_seconds' => env('LARAVEL_MESSENGER_LOG_RATE_LIMIT_DECAY_SECONDS', 60), ], ], 'kinesis' => [ 'class' => Lostlink\Messenger\Drivers\Kinesis::class, 'name' => env('LARAVEL_MESSENGER_KINESIS_STREAM_NAME'), 'region' => env('LARAVEL_MESSENGER_KINESIS_STREAM_AWS_REGION', env('AWS_DEFAULT_REGION')), 'aws_key' => env('LARAVEL_MESSENGER_KINESIS_STREAM_AWS_KEY', env('AWS_ACCESS_KEY_ID')), 'aws_secret_key' => env('LARAVEL_MESSENGER_KINESIS_STREAM_AWS_SECRET_KEY', env('AWS_SECRET_ACCESS_KEY')), 'rate_limit' => [ 'enabled' => env('LARAVEL_MESSENGER_KINESIS_RATE_LIMIT_ENABLED', false), 'max_attempts' => env('LARAVEL_MESSENGER_KINESIS_RATE_LIMIT_MAX_ATTEMPTS', 10), 'decay_seconds' => env('LARAVEL_MESSENGER_KINESIS_RATE_LIMIT_DECAY_SECONDS', 60), ], ], 'tinybird' => [ 'class' => Lostlink\Messenger\Drivers\Tinybird::class, 'name' => env('LARAVEL_MESSENGER_TINYBIRD_DATA_SOURCE_NAME'), 'token' => env('LARAVEL_MESSENGER_TINYBIRD_TOKEN'), 'endpoint' => env('LARAVEL_MESSENGER_TINYBIRD_ENDPOINT', 'https://api.us-east.aws.tinybird.co/v0/events'), 'rate_limit' => [ 'enabled' => env('LARAVEL_MESSENGER_TINYBIRD_RATE_LIMIT_ENABLED', false), 'max_attempts' => env('LARAVEL_MESSENGER_TINYBIRD_RATE_LIMIT_MAX_ATTEMPTS', 40), // Free tier limit 'decay_seconds' => env('LARAVEL_MESSENGER_TINYBIRD_RATE_LIMIT_DECAY_SECONDS', 3600), // Free tier limit ], ], ], ]; ``` ### Available Environment Variables [](#available-environment-variables) OptionDescription`LARAVEL_MESSENGER_DRIVER`Specifies the driver to use (`log`, `kinesis`, or `tinybird`).`LARAVEL_MESSENGER_LOG_RATE_LIMIT_ENABLED`Enable rate limiting for the log driver.`LARAVEL_MESSENGER_LOG_RATE_LIMIT_MAX_ATTEMPTS`The maximum number of attempts before rate limiting is enforced for the Log driver. A value of 0 is the same a being disabled`LARAVEL_MESSENGER_LOG_RATE_LIMIT_DECAY_SECONDS`The number of seconds before the rate limit resets for the log driver.`LARAVEL_MESSENGER_KINESIS_STREAM_NAME`The name of the Kinesis stream.`LARAVEL_MESSENGER_KINESIS_STREAM_AWS_REGION`The AWS region where the Kinesis stream is located. Defaults to `AWS_DEFAULT_REGION` if not set.`LARAVEL_MESSENGER_KINESIS_STREAM_AWS_KEY`The AWS access key for Kinesis. Defaults to `AWS_ACCESS_KEY_ID`.`LARAVEL_MESSENGER_KINESIS_STREAM_AWS_SECRET_KEY`The AWS secret key for Kinesis. Defaults to `AWS_SECRET_ACCESS_KEY`.`LARAVEL_MESSENGER_KINESIS_RATE_LIMIT_ENABLED`Enable rate limiting for the Kinesis driver.`LARAVEL_MESSENGER_KINESIS_RATE_LIMIT_MAX_ATTEMPTS`The maximum number of attempts before rate limiting is enforced for the Kinesis driver. A value of 0 is the same a being disabled`LARAVEL_MESSENGER_KINESIS_RATE_LIMIT_DECAY_SECONDS`The number of seconds before the rate limit resets for the Kinesis driver.`LARAVEL_MESSENGER_TINYBIRD_DATA_SOURCE_NAME`The name of the Tinybird data source.`LARAVEL_MESSENGER_TINYBIRD_TOKEN`The API token for Tinybird.`LARAVEL_MESSENGER_TINYBIRD_ENDPOINT`The Tinybird API endpoint. Defaults to `https://api.us-east.aws.tinybird.co/v0/events`.`LARAVEL_MESSENGER_TINYBIRD_RATE_LIMIT_ENABLED`Enable rate limiting for the Tinybird driver.`LARAVEL_MESSENGER_TINYBIRD_RATE_LIMIT_MAX_ATTEMPTS`The maximum number of attempts before rate limiting is enforced for the Tinybird driver. A value of 0 is the same a being disabled`LARAVEL_MESSENGER_TINYBIRD_RATE_LIMIT_DECAY_SECONDS`The number of seconds before the rate limit resets for the Tinybird driver.Usage ----- [](#usage) Sending messages with `LostLink Laravel-Messenger` is simple. After configuring your environment variables, you can use the `send` method: ``` use \Lostlink\Messenger\Messenger; Messenger::send([ "timestamp" => "2022-10-27T11:43:02.099Z", "transaction_id" => "8d1e1533-6071-4b10-9cda-b8429c1c7a67", "name" => "Bobby Drake", "email" => "bobby.drake@pressure.io", "age" => 42, "passport_number" => 3847665, "flight_from" => "Barcelona", "flight_to" => "London", "extra_bags" => 1, "flight_class" => "economy", "priority_boarding" => false, "meal_choice" => "vegetarian", "seat_number" => "15D", "airline" => "Red Balloon" ]); ``` ### Updating Configuration on the Fly [](#updating-configuration-on-the-fly) You can modify the configuration for a specific message by chaining and passing an array to the `config([])` method. This allows you to override the default driver settings for that particular message. Here's an example: ``` use \Lostlink\Messenger\Messenger; Messenger::send([ "timestamp" => "2022-10-27T11:43:02.099Z", "transaction_id" => "8d1e1533-6071-4b10-9cda-b8429c1c7a67", "name" => "Bobby Drake", "email" => "bobby.drake@pressure.io", "age" => 42, "passport_number" => 3847665, "flight_from" => "Barcelona", "flight_to" => "London", "extra_bags" => 1, "flight_class" => "economy", "priority_boarding" => false, "meal_choice" => "vegetarian", "seat_number" => "15D", "airline" => "Red Balloon" ]) ->driver('tinybird') // Change the driver to "tinybird" for this message ->config([ 'name' => 'example_events', // Change the data source name to "example_events" for this message 'token' => 'your_token', // Change the token for this message 'endpoint' => 'https://api.us-east.aws.tinybird.co/v0/events', // Change the endpoint for this message 'rate_limit' => [ 'enabled' => true, // Enable rate limiting for this message to use Tinybird Free Tier @ 1000/day 'max_attempts' => 40, // Set the maximum number of attempts before rate limiting is enforced 'decay_seconds' => 3600, // Set the number of seconds before the rate limit resets ], ]); ``` ### Adding Custom Drivers [](#adding-custom-drivers) To create and add your own driver, simply extend the driver system by implementing the required interfaces. 1. Make sure to publish the laravel-messenger config file ``` php artisan vendor:publish --tag=messenger-config ``` 2. Adjust the laravel-messenger config with the name and class of your custom driver ``` return [ ... 'drivers' => [ ... 'mycustomdriver' => [ 'class' => \App\Messenger\Drivers\MyCustomDriver::class, 'name' => env('MY_CUSTOM_DRIVER_NAME'), 'token' => env('MY_CUSTOM_DRIVER_TOKEN'), 'endpoint' => env('MY_CUSTOM_DRIVER_ENDPOINT'), 'rate_limit' => [ 'enabled' => env('MY_CUSTOM_DRIVER_RATE_LIMIT_ENABLED', false), 'max_attempts' => env('MY_CUSTOM_DRIVER_RATE_LIMIT_MAX_ATTEMPTS', 10), 'decay_seconds' => env('MY_CUSTOM_DRIVER_RATE_LIMIT_DECAY_SECONDS', 60), ], ], ], ... ]; ``` 3. Create a class that extends \\LostLink\\Drivers\\Driver ``` class MyCustomDriver extends Driver { public function handle(): void { $response = Http::withToken($this->message->token ?? $this->message->config->get('token')) ->acceptJson() ->withQueryParameters([ 'name' => $this->message->stream ?? $this->message->config->get('name'), ]) ->post( $this->message->endpoint ?? $this->message->config->get('endpoint'), $this->message->body ); $response->throw(); } } ``` ``` License ------- [](#license) This package is open-sourced software licensed under the [MIT license](LICENSE). ### Health Score 34 — LowBetter than 77% of packages Maintenance36 Infrequent updates — may be unmaintained Popularity17 Limited adoption so far Community7 Small or concentrated contributor base Maturity64 Established project with proven stability Bus Factor1 Top contributor holds 100% of commits — single point of failure How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window. **Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores. **Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement. **Maturity (30%)** — Project age, version count, PHP version support, and release stability. ### Release Activity Cadence Every ~64 days Recently: every ~2 days Total 8 Last Release 585d ago Major Versions 1.0.1 → 2.0.02024-09-20 PHP version history (2 changes)1.0.0PHP ^8.0 2.0.0PHP ^8.0||^8.1||^8.2||^8.3 ### Community Maintainers ![](https://www.gravatar.com/avatar/a456824eef06ee07468b4d8d0b6dafe2330e38c7b1f7c6c383a9060967ede4eb?d=identicon)[nsouto](/maintainers/nsouto) --- Top Contributors [![nsouto](https://avatars.githubusercontent.com/u/986996?v=4)](https://github.com/nsouto "nsouto (12 commits)") ### Code Quality TestsPHPUnit Code StyleLaravel Pint ### Embed Badge ![Health badge](/badges/lostlink-laravel-messenger/health.svg) ``` [![Health](https://phpackages.com/badges/lostlink-laravel-messenger/health.svg)](https://phpackages.com/packages/lostlink-laravel-messenger) ``` ### Alternatives [league/flysystem-aws-s3-v3 AWS S3 filesystem adapter for Flysystem. 1.6k263.6M788](/packages/league-flysystem-aws-s3-v3)[aws/aws-sdk-php-laravel A simple Laravel 9/10/11/12/13 service provider for including the AWS SDK for PHP. 1.7k35.6M74](/packages/aws-aws-sdk-php-laravel)[humanmade/s3-uploads WordPress plugin to store uploads on S3 2.1k2.4M8](/packages/humanmade-s3-uploads)[bref/laravel-bridge An advanced Laravel integration for Bref, including Octane support. 3384.1M11](/packages/bref-laravel-bridge)[magento/magento2-functional-testing-framework Magento2 Functional Testing Framework 15511.5M30](/packages/magento-magento2-functional-testing-framework)[laravel-notification-channels/aws-sns Amazon Simple Notification Service (AWS SNS) notification channel for Laravel. 541.1M2](/packages/laravel-notification-channels-aws-sns) PHPackages © 2026 [Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)