src/HealthCheck/MessengerTransportHealthCheck.php line 28

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\HealthCheck;
  7. use App\Message\HealthCheckMessage\IbexaHealthCheckMessage;
  8. use Symfony\Component\Messenger\MessageBusInterface;
  9. use Symfony\Component\Messenger\Stamp\SentStamp;
  10. use SymfonyHealthCheckBundle\Check\CheckInterface;
  11. use SymfonyHealthCheckBundle\Dto\Response;
  13. class MessengerTransportHealthCheck implements CheckInterface
  14. {
  15. public function __construct(private readonly MessageBusInterface $messageBus)
  16. {
  17. }
  19. protected static function buildHealthCheckMessage(): IbexaHealthCheckMessage
  20. {
  21. return new IbexaHealthCheckMessage();
  22. }
  24. public function check(): Response
  25. {
  26. $healthCheckMessage = static::buildHealthCheckMessage();
  27. try {
  28. $healthCheckEnvelope = $this->messageBus->dispatch($healthCheckMessage);
  29. $sentStamp = $healthCheckEnvelope->last(SentStamp::class);
  31. if ($sentStamp?->getSenderAlias() !== $healthCheckMessage->getMessengerTransport()) {
  32. throw new \RuntimeException('Health Check message was not sent correctly!');
  33. }
  35. return new Response('messenger_transport_'.$healthCheckMessage->getMessengerTransport(), $sentStamp?->getSenderAlias() === $healthCheckMessage->getMessengerTransport(), 'up');
  36. } catch (\Throwable $throwable) {
  37. return new Response('messenger_transport_'.$healthCheckMessage->getMessengerTransport(), false, $throwable->getMessage());
  38. }
  39. }
  40. }