We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents ec19912 + ef39ba6 commit 643e691Copy full SHA for 643e691
src/Service/Sns/SnsTransport.php
@@ -41,7 +41,7 @@ public function send(Envelope $envelope): Envelope
41
if (str_contains($this->topic, ".fifo")) {
42
$stamps = $envelope->all();
43
$dedupeStamp = $stamps[SnsFifoStamp::class][0] ?? false;
44
- if (!$dedupeStamp) {
+ if (!$dedupeStamp || $dedupeStamp instanceof SnsFifoStamp == false) {
45
throw new Exception("SnsFifoStamp required for fifo topic");
46
}
47
$messageGroupId = $dedupeStamp->getMessageGroupId() ?? false;
0 commit comments