symfony event handler that runs when a message has been rejected (all retries attempted and failed)

MessageOnRejectionSubscriber.php

<?php

class MessageOnRejectionSubscriber implements EventSubscriberInterface {
	public function onMessageFailed(WorkerMessageFailedEvent $event) {
		// return early if there is still more retrying to do
		if ($event->willRetry()) {
			return;
		}
    
		$envelope = $event->getEnvelope();
		echo "Message failure caught by ".self::class."\n";
	}

	public static function getSubscribedEvents() {
		return [
			WorkerMessageFailedEvent::class => ['onMessageFailed', -100],
		];
	}
}