2 Commits
Author SHA1 Message Date
viktor 8320fb4a84 Version 1.2.0
- Event publishing without queue
- Broadcastable event can be non json serializable
2026-02-27 00:44:57 +04:00
viktor 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
+1 -1
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",
Generated
+243 -258
View File
File diff suppressed because it is too large Load Diff
+1 -3
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;
+4 -4
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'
);
}
}