public function reset(): void
{ if (null !==
$this->currentResponse
) { // fetch current response in order to requeue in transit messages
if (!
$this->
fetchMessage()) { $this->currentResponse->
cancel();
$this->currentResponse = null;
} } foreach ($this->
getPendingMessages() as $message) { $this->client->
changeMessageVisibility([ 'QueueUrl' =>
$this->
getQueueUrl(),
'ReceiptHandle' =>
$message['id'
],
'VisibilityTimeout' => 0,
]);
} } private function getQueueUrl(): string
{ if (null !==
$this->queueUrl
) { return $this->queueUrl;
}