$messageDeduplicationId = null;
/** @var AmazonSqsFifoStamp|null $amazonSqsFifoStamp */
$amazonSqsFifoStamp =
$envelope->
last(AmazonSqsFifoStamp::
class);
if (null !==
$amazonSqsFifoStamp) { $messageGroupId =
$amazonSqsFifoStamp->
getMessageGroupId();
$messageDeduplicationId =
$amazonSqsFifoStamp->
getMessageDeduplicationId();
} /** @var AmazonSqsXrayTraceHeaderStamp|null $amazonSqsXrayTraceHeaderStamp */
$amazonSqsXrayTraceHeaderStamp =
$envelope->
last(AmazonSqsXrayTraceHeaderStamp::
class);
$xrayTraceId =
$amazonSqsXrayTraceHeaderStamp?->
getTraceId();
try { $this->connection->
send( $encodedMessage['body'
],
$encodedMessage['headers'
] ??
[],
$delay,
$messageGroupId,
$messageDeduplicationId,
$xrayTraceId );
} catch (HttpException
$e) {