Compare commits

...

2 Commits

Author SHA1 Message Date
8320fb4a84 Version 1.2.0
- Event publishing without queue
- Broadcastable event can be non json serializable
2026-02-27 00:44:57 +04:00
c481c961fb Broadcastable event shouldnt be a JsonSerializable everytime 2026-02-27 00:43:06 +04:00
4 changed files with 249 additions and 266 deletions

View File

@@ -3,7 +3,7 @@
"description": "A laravel package for events emitting between services using RabbitMQ as message broker.",
"type": "library",
"license": "MIT",
"version": "1.1.0",
"version": "1.2.0",
"keywords": [
"laravel", "rabbitmq", "event", "emit", "microservice",
"pipeline", "data exchanging", "message", "broker", "php8",

501
composer.lock generated

File diff suppressed because it is too large Load Diff

View File

@@ -4,9 +4,7 @@ declare(strict_types=1);
namespace Diffhead\PHP\LaravelRabbitMQ\Event;
use JsonSerializable;
interface Broadcast extends JsonSerializable
interface Broadcast
{
public function getConnection(): string;
public function getQueue(): string;

View File

@@ -11,16 +11,16 @@ use PhpAmqpLib\Message\AMQPMessage;
class Serializer implements SerializerInterface
{
public function serialize(object $data): AMQPMessage
public function serialize(object $event): AMQPMessage
{
if ($data instanceof JsonSerializable) {
if ($event instanceof JsonSerializable) {
return new AMQPMessage(
json_encode($data->jsonSerialize())
json_encode($event->jsonSerialize())
);
}
throw new InvalidArgumentException(
'Data should be an instance of BroadcastEvent'
'Event should be an instance of JsonSerializable'
);
}
}