gps

Author: ASKozienko

pkg/gps/GpsProducer.php

@@ -5,6 +5,7 @@
 use Google\Cloud\PubSub\Topic;
 use Interop\Queue\DeliveryDelayNotSupportedException;
 use Interop\Queue\InvalidDestinationException;
+use Interop\Queue\InvalidMessageException;
 use Interop\Queue\PriorityNotSupportedException;
 use Interop\Queue\PsrDestination;
 use Interop\Queue\PsrMessage;
@@ -32,6 +33,7 @@ public function __construct(GpsContext $context)
     public function send(PsrDestination $destination, PsrMessage $message)
     {
         InvalidDestinationException::assertDestinationInstanceOf($destination, GpsTopic::class);
+        InvalidMessageException::assertMessageInstanceOf($message, GpsMessage::class);
 
         /** @var Topic $topic */
         $topic = $this->context->getClient()->topic($destination->getTopicName());