Event Backbone Laravel
Package for convenient usage of Event Driven Microservices communication using Event Backbone (for now only Apache Kafka is supported).
Installation
You can install the package via composer:
composer require vmorozov/event-backbone-laravelYou will have to publish the config file with:
php artisan vendor:publish --tag="event-backbone-laravel-config"Usage
Producing events
To start producing events you have to create your first event that implements Vmorozov\EventBackboneLaravel\Producer\ExternalEvent interface.
<?php
namespace App\Events;
use App\Models\User;
use Illuminate\Broadcasting\InteractsWithSockets;
use Illuminate\Foundation\Events\Dispatchable;
use Illuminate\Queue\SerializesModels;
use Vmorozov\EventBackboneLaravel\Producer\ExternalEvent;
class UserCreated implements ExternalEvent
{
use Dispatchable, InteractsWithSockets, SerializesModels;
private User $user;
public function __construct(User $user)
{
$this->user = $user;
}
public function getTopic(): string
{
return 'users';
}
public function getName(): string
{
return 'user_created';
}
public function getKey(): string
{
return $this->user->getKey();
}
public function getPayload()
{
return $this->user->toJson();
}
public function getHeaders(): array
{
return [];
}
}Then you have to fire event created in previous step.
use App\Events\UserCreated;
// some code here
event(new UserCreated($user));Consuming events
To start consuming events you have to create your first event that implements Vmorozov\EventBackboneLaravel\Consumer\ExternalConsumedEvent interface and create Laravel Event Listener for it.
Here is the example for consuming event produced in "Producing events" section.
Create event:
<?php
namespace App\Events;
use Illuminate\Broadcasting\InteractsWithSockets;
use Illuminate\Foundation\Events\Dispatchable;
use Illuminate\Queue\SerializesModels;
use Vmorozov\EventBackboneLaravel\Consumer\ExternalConsumedEvent;
class UserCreatedConsumedEvent implements ExternalConsumedEvent
{
use Dispatchable, InteractsWithSockets, SerializesModels;
private array $payload;
public function __construct(array $payload)
{
$this->payload = $payload;
}
public function getId()
{
return $this->payload['id'];
}
public function getName(): string
{
return $this->payload['name'];
}
public function getEmail(): string
{
return $this->payload['email'];
}
}Create listener:
<?php
namespace App\Listeners;
use App\Events\UserCreatedConsumedEvent;
use App\Models\User;
use Illuminate\Contracts\Queue\ShouldQueue;
class UserCreatedListener implements ShouldQueue
{
/**
* Create the event listener.
*
* @return void
*/
public function __construct()
{
//
}
/**
* Handle the event.
*
* @param object $event
* @return void
*/
public function handle(UserCreatedConsumedEvent $event): void
{
if (User::query()->find($event->getId())) {
return;
}
User::unguard();
User::query()->create([
'id' => $event->getId(),
'name' => $event->getName(),
'email' => $event->getEmail(),
]);
}
}Register your listener in EventServiceProvider:
protected $listen = [
\App\Events\UserCreatedConsumedEvent::class => [
\App\Listeners\UserCreatedListener::class,
],
];To start consuming events run following artisan command:
php artisan event_backbone:consumeTesting
composer testChangelog
Please see CHANGELOG for more information on what has changed recently.
Contributing
Please see CONTRIBUTING for details.
Security Vulnerabilities
Please review our security policy on how to report security vulnerabilities.
Credits
License
The MIT License (MIT). Please see License File for more information.
