我有一個(gè)簡(jiǎn)單的信使配置：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)該在消息重定向時(shí)向我發(fā)送電子郵件通知。我唯一的想法是定期檢查messenger_messages包含存儲(chǔ)在失敗傳輸中的消息的表，但我認(rèn)為這不是 symfony 方式的解決方案。你知道這個(gè)功能更聰明的解決方案嗎？我正在使用版本 5.* 的 symfony/messenger
2 回答
慕田峪4524236
TA貢獻(xiàn)1875條經(jīng)驗(yàn) 獲得超5個(gè)贊
最終，我應(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)標(biāo)記為kernel.event_subscriber或自動(dòng)配置。
我沒(méi)有使用中間件，因?yàn)?Messenger 直接將消息發(fā)送到失敗的傳輸，沒(méi)有中間件。
守著一只汪
TA貢獻(xiàn)1872條經(jīng)驗(yàn) 獲得超4個(gè)贊
我認(rèn)為不可能通過(guò)配置來(lái)完成，但您可以創(chuàng)建自定義中間件并自行發(fā)送電子郵件。
- 2 回答
- 0 關(guān)注
- 183 瀏覽
添加回答
舉報(bào)
0/150
提交
取消