我有一個簡單的信使配置：framework: messenger: failure_transport: failed transports: async: dsn: '%env(MESSENGER_TRANSPORT_DSN)%' retry_strategy: max_retries: 2 delay: 10000 failed: 'doctrine://default?queue_name=failed' routing: someInterface: async我想知道路由到失敗的傳輸 fe 系統(tǒng)的每條消息都應(yīng)該在消息重定向時向我發(fā)送電子郵件通知。我唯一的想法是定期檢查messenger_messages包含存儲在失敗傳輸中的消息的表，但我認為這不是 symfony 方式的解決方案。你知道這個功能更聰明的解決方案嗎？我正在使用版本 5.* 的 symfony/messenger
2 回答
慕田峪4524236
TA貢獻1875條經(jīng)驗 獲得超5個贊
最終，我應(yīng)用了以下解決方案：
<?php
/**
* Author: writ3it
*/
namespace App\Maintenance\Messenger;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
use Symfony\Component\Messenger\MessageBusInterface;
class FailedMessageListener implements EventSubscriberInterface
{
/**
* @var MessageBusInterface
*/
private MessageBusInterface $bus;
public function __construct(MessageBusInterface $bus)
{
$this->bus = $bus;
}
public function onMessageFailed(WorkerMessageFailedEvent $event)
{
if ($event->willRetry()) {
return;
}
$envelope = $event->getEnvelope();
$message = $envelope->getMessage();
$subject = sprintf("Message added to failed transport. Message: %s", \get_class($message));
$content = serialize($message);
$notification = new FailedMessageNotificationEvent();
$notification->setSubject($subject)
->setContent($content);
$this->bus->dispatch($notification);
}
/**
* @return array
*/
public static function getSubscribedEvents()
{
return [
WorkerMessageFailedEvent::class => ['onMessageFailed', -256],
];
}
}
FailedMessageNotificationEvent是一條將被我的郵件處理程序捕獲的消息。該類FailedMessageListener應(yīng)標記為kernel.event_subscriber或自動配置。
我沒有使用中間件，因為 Messenger 直接將消息發(fā)送到失敗的傳輸，沒有中間件。
- 2 回答
- 0 關(guān)注
- 170 瀏覽
添加回答
舉報
0/150
提交
取消