diff --git a/src/Event/Broadcast.php b/src/Event/Broadcast.php index 6c6608c..cbb2448 100644 --- a/src/Event/Broadcast.php +++ b/src/Event/Broadcast.php @@ -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; diff --git a/src/Service/Serializer.php b/src/Service/Serializer.php index 7ae1aa5..8e632a9 100644 --- a/src/Service/Serializer.php +++ b/src/Service/Serializer.php @@ -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' ); } }