Messenger

Question 1

Quels sont les 2 composantes essentiels de Messenger

Answer 1

une class Message (data) + une class Handler (read data + process)

Question 2

quels sont les composantes d’une class Message Handler de Messenger

Answer 2

doit être Callable (__invoke()) + Attribute #[AsMessageHandler]

Question 3

comment lister tous les Messenger Handler

Answer 3

php bin/console debug:messenger

Question 4

comment procéder pour envoyer un message

Answer 4

utiliser le service MessageBusInterface avec la methode dispatch() et en argument la class Message (le handler sera ensuite invoker)

Question 5

que fait-il faire pour faire du Messenger Async

Answer 5

utiliser un Transports (send to queueing + receive via worker)

Question 6

comment est enregistrer un Messenger

Answer 6

par une config DSN

Question 7

comment est configurer un Messenger

Answer 7

config/packages/messenger.yaml (framework:messenger:transports)

Question 8

comment déclarer un message en Async

Answer 8

framework:messenger:routing:’ClassMessage’: async

Question 9

quel probleme doit etre eviter quand on utilise l’héritage de class Messenger

Answer 9

si on déclare à la fois le parent et le child d’un message alors il sera expédié 2 fois

Question 10

Que faut-il éviter de faire si on souhaite travailler avec une Entity pour data d’un Message

Answer 10

ne pas envoyer l’objet entity tel quel mais uniquement son ID et c’est le handler qui sera en charge de le reloader avec son ID.

Question 11

comment lancer le worker SF pour les messages

Answer 11

php bin/console messenger:consume async

Question 12

a quoi faut-il faire attention avec le worker messenger SF en prod

Answer 12

1/ ne pas le laisser run forever 2/ utiliser un process control pour gérer les workers (supervisor ou systemd) 3/ stopper les workers si errors 4/restart workers on deploy 5/ use same cache namespace between deploy

Question 13

comment gérer la priorité entre des messages

Answer 13

il faut créer des transport différents tagger par des priorités différentes et ensuite déclarer les messages suivant ces tag de transport priorité

Question 14

comment consume unique les messages de haut priorité

Answer 14

php bin/console messenger/consume async_priority_high

Question 15

a quoi est lié le transport SF par rapport au broker

Answer 15

SF transport est lié par l’exchange du broker

Question 16

que fais par defaut le worker SF par rapport au broker

Answer 16

il consume toutes les queues de l’exchange

Question 17

Comment dire à SF worker de ne consume que les messages de certaines queue de l’exchange

Answer 17

pgp bin/console messenger:consume my_transport –queus=fasttrack

Question 18

comment obtenir des stats par rapport au worker

Answer 18

php bin/console messenger:stats

Question 19

comment faire un sorte d’avoir un worker Stateless qui ne conserve pas de state de service SF entre chaq message

Answer 19

il faut faire en sorte que les services impl l’I ResetInterface et call la methode reset() entre chq message

Question 20

Comment gérer les error d’envoi de messages

Answer 20

utiliser une “retry_strategy” dans la config avec les options suivantes : max_retries, delay, multiplier, max_delay, jitter

Question 21

Comment éviter de retry une error d’envoi de message

Answer 21

il faut lancer une exception “RecoverableMessageHandlingException”

Question 22

comment gérer les messages qui sont en error au max_retries

Answer 22

il faut créer un transport spécial error pour pouvoir les gérer

Question 23

comment passer des options de transport DSN

Answer 23

dans la string DSN directement ou dans la config

Question 24

comment passer des options supplémentaires spécifique à un message

Answer 24

dans le message meme il faut utiliser AmqpStamp class

Question 25

comment utiliser Doctrine avec messenger

Answer 25

avec le bundle symfony/doctrine-messenger

Question 26

comment Trigger une command avec un message SF

Answer 26

dans le dispatcher il faut utiliser un obj RunCommandMessage

Question 27

comment Trigger un process system avec un message SF

Answer 27

dans le dispatcher il faut utiliser un obj RunProcessMessage

Question 28

comment Trigger un ping de WS avec un message SF

Answer 28

dans le dispatcher il faut utiliser un obj PingWebhookMessage

Question 29

est-il possible de faire du transactionnal message

Answer 29

oui un handler de message peut également dispatch de new message à son tour

Question 30

comment process many message with batch

Answer 30

en extends BatchHandlerInterface et use BatchHandlerTrait

Question 31

comment ajouter un delay de process coté broker pour un message

Answer 31

en ajoutant un DelayStamp au message (info qui se traité par le broker)

Question 32

quel sont les 9 Event pouvant être listener en rapport à Messenger

Answer 32

SendMessageToTransportEvent, WorkerMessageFailedEvent, WorkerMessageHandledEvent, WorkerMessageReceivedEvent, WorkerMEssageRetriedEvent, WorkerRateLimited, WorkerRunningEvent, WorkerStartedEvent, WorkerStoppedEvent

Question 33

comment faire si le message receptionné par le handler n’est pas du format classique JSON

Answer 33

il faut utiliser un serializer dédié

Question 34

que doit-on faire si on veut faire du CQRS avec messenger

Answer 34

séparer les Bus Message en 3 : Command, Query & Event

Question 35

comment redispatcher un message dans le handler

Answer 35

il faut utiliser la Class RedispatchMessage