Описание тега symfony-messenger
1
ответ
Юнит тест Symfony Messenger
Я возился с реализацией AMQP с использованием Symfony Messenger в моем последнем проекте. Хотя код работает к моей большой радости, я не могу написать модульные тесты для методов, которые отправляют сообщения. Все мои тесты с кодом, который отправля…
09 янв '19 в 21:05
0
ответов
Symfony Worker - потреблять сообщения - EntityManager
Я использую Symfony 4 с мессенджером и использую работника, который использует мои сообщения как длительный процесс. У меня есть ошибка с доктриной, если я удаляю свой пост, воссоздаю новый и отправляю свое сообщение. $ post содержит старые данные, …
13 дек '18 в 15:37
1
ответ
Обработка ошибок потребителей в Symfony Messenger / RabbitMQ
Я использую новые компоненты Symfony Messenger 4.1 и RabbitMQ 3.6.10-1 для постановки в очередь и асинхронной отправки уведомлений по электронной почте и SMS из моего веб-приложения Symfony 4.1. Конфигурация моего мессенджера (messenger.yaml) выгляд…
30 окт '18 в 15:59
0
ответов
Symfony Messenger с SQS не обрабатывает исключения для запроса сообщения
Я видел, что AmqpExt правильно обрабатывает исключения, но использует компонент messenger с транспортом SQS, после исключений сообщения снова не видны. Как я могу сделать сообщение видимым после исключений?
13 ноя '18 в 21:38
1
ответ
Symfony messenger не может принимать сообщения
Несколько недель назад я установил систему сообщений с Symfony Messenger, и она отлично работала. Сегодня я хотел создать новый объект с помощью сообщения, поэтому я пошел на свой сервер и набрал команду, чтобы использовать сообщение Сначала у меня …
30 янв '19 в 22:58
0
ответов
Как использовать сообщения из Cloud Pub/Sub с помощью компонента Messenger адаптера Symfony и Enqueue?
Инструменты, которые я использую: Symfony 4.1.6 Компонент Symfony Messenger 4.1.6 Поставить в очередь адаптер 0.1.2 Поставить в очередь Google Cloud Pub/Sub Transport 0.8.37 Мои конфигурационные файлы: #service.yaml framework: messenger: transports:…
12 окт '18 в 09:21
0
ответов
Symfony 4 - Использование мессенджера для запуска фоновой задачи после проверки формы
Я хотел бы запустить фоновое задание на Symfony 4, основываясь на настройке формы. Это позволит избежать того, что пользователь должен оставаться в форме, пока задача не будет завершена. Идея заключается в том, что когда форма проверена, она запуска…
22 янв '19 в 09:51
0
ответов
Справка по настройке для symfony-messenger php-enqueue messenger-adapter Очереди FIFO Amazon SQS
При отправке сообщений в очереди FIFO параметр MessageGroupId обязателен. Как настроить транспорт для очереди.fifo? enqueue.yaml enqueue: default: transport: "%env(ENQUEUE_DSN)%" client: ~ messenger.yaml framework: messenger: transports: sqs: enqueu…
07 дек '18 в 09:04
0
ответов
Как получить доступ к шине транспорта из пользовательского промежуточного программного обеспечения для компонента Messenger?
При определении пользовательских промежуточных программ для Symfony Messenger иногда бывает полезно получить доступ к транспорту для работы с сообщением и очередью. Например, добавление сообщения в очередь с другими параметрами или удаление сообщени…
25 май '19 в 11:51
1
ответ
Пользовательское исключение из обработчика Messenger
Я пробую версию Symfony 4.3.0-dev, чтобы получить некоторые новые функции из компонента Messenger. Моя командная шина работает в режиме синхронизации. Перед обновлением я мог легко вернуть свое пользовательское исключение ConflictException из обрабо…
07 апр '19 в 11:11
1
ответ
Используйте Messenger, чтобы прочитать сообщение в очереди, не отправленное с Messenger
Я пытаюсь прочитать сообщение в очереди (в RabbitMQ), которое не было отправлено с Symfony Messenger. Похоже, что Messenger добавляет несколько заголовков, таких как headers: type: App\Message\Transaction но при чтении внешних сообщений этот заголов…
08 апр '19 в 16:00
0
ответов
Как украсить MessageBus с помощью функции handle, как в HandleTrait
Я хочу украсить мою шину запросов Symfony Messenger функцией handle, чтобы получить результат от обработчика. Здесь это уже понято, но я не хочу использовать эту черту. Я хочу создать свой собственный класс QueryBus с функцией handle, чтобы получить…
27 май '19 в 06:32
1
ответ
Symfony 4 amqp/messenger создать PDF
Мне нужно было отправить электронное письмо с прикрепленным PDF. Все это было довольно просто сделать с помощью SnappyBundle и Swift Mailer. Всякий раз, когда звонят ../document_name/{id}/mail PDF создается и электронная почта отправляется. Чтобы по…
15 мар '19 в 19:57
2
ответа
Работник Symfony 4, использующий доктрину, не работает должным образом: SQLSTATE[HY000] [2002] Истекло время соединения
Я использую рабочий с мессенджером Symfony 4. Этот работник получение сообщения (от rabbitMQ) запустить ffmpeg сделать лечение на видео и сохранить что-то в базе данных. Чтобы настроить этого работника в Symfony, я сделал это (промежуточное программ…
23 авг '19 в 16:22
2
ответа
Как проверить, что события Symfony Messenger отправляются в сценарии с несколькими шинами с использованием Behat?
Кажется сложным, и нет много документации по этому поводу (я использую расширение FirendsOfBehat Symfony). Я хочу проверить, Transport переносит любые события, используя get() метод, но я не получаю никаких результатов. Такое ощущение, что он не нап…
30 авг '19 в 17:23
0
ответов
Является ли использование Symfony Messenger в качестве динамического конвейера злоупотреблением им?
Я не использовал Symfony Messenger, кроме нескольких простых тестов. Я думаю, что я понял концепцию в целом (имея сообщения и специальные обработчики для них, давая шине мое сообщение и позволяя ей найти правильный обработчик для работы с ним), но в…
29 авг '19 в 14:23
0
ответов
Как лучше всего запустить Symfony Messenger Worker в Кубернетесе
Какой лучший способ запустить messenger:consume задание на Кубернетес? Развертывание? Если мы сделаем это с развертыванием с определенным количеством реплик, это может сработать, но что, если мы сделаем обновление по мере развертывания, которое зате…
03 июл '19 в 18:38
1
ответ
Symfony Messenger 4.3 - сбой при получении сообщений от транспорта доктрин (исключение выдается)
Версия Symfony: 4.3.2 PHP: 7.2.20 Я пытаюсь использовать компонент мессенджера с транспортом доктрины асинхронно. Я установил мессенджер через composer require messenger с помощью Symfony Flex. Я активировал доктрину транспорта MESSENGER_TRANSPORT_D…
25 июл '19 в 15:54
1
ответ
Как Symfony Messenger определяет, какой обработчик должен обрабатывать каждый тип сообщения?
Я пытаюсь реализовать обмены в кролике и Symfony, используя компонент Messenger. Допустим, у нас есть транспорт: messenger: transports: amqp_image_resize: dsn: '%env(MESSENGER_TRANSPORT_DSN)%' options: exchange: name: image_resize_ex type: fanout qu…
13 авг '19 в 12:57
0
ответов
Получена ошибка "Недопустимая конфигурация маршрутизации Messenger" при попытке настроить класс маршрутизации
Поэтому я использую Symfony/ Messenger. Сейчас я пытаюсь настроить маршрутизацию мессенджера, но всегда получаю ту же ошибку. Invalid Messenger routing configuration: class or interface "message_class" not found. Я попытался создать свой код: <fr…
15 авг '19 в 10:20