Exclude non sendable stamps

kunicmarko20 · Jul 7, 2019 · 1d9e0ca · 1d9e0ca
1 parent 3bcf81b
commit 1d9e0ca
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/Serializer.php b/src/Serializer.php
@@ -8,6 +8,7 @@
 use KunicMarko\JMSMessengerAdapter\Stamp\DeserializationContextStamp;
 use KunicMarko\JMSMessengerAdapter\Stamp\SerializationContextStamp;
 use Symfony\Component\Messenger\Envelope;
+use Symfony\Component\Messenger\Stamp\NonSendableStampInterface;
 use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
 use JMS\Serializer\SerializerInterface as JMSSerializerInterface;
 
@@ -94,6 +95,8 @@ public function encode(Envelope $envelope): array
             $context = $serializerStamp->getContext();
         }
 
+        $envelope = $envelope->withoutStampsOfType(NonSendableStampInterface::class);
+
         $headers = ['type' => \get_class($envelope->getMessage())] + $this->encodeStamps($envelope);
 
         return [