Skip to main content
Filter by
Sorted by
Tagged with
1 vote
0 answers
18 views

does my Symfony 7.1 web application necessarily need doctrine-messenger?

I am working on a scheduling and billing system for a clinical psychology solo practice. The data persistence will be handled by Doctrine and mariadb. Evidently, the symfony/messenger component is ...
David's user avatar
  • 855
-1 votes
1 answer
15 views

Symfony Messenger with CloudEvents and multiple queues

I am implementing CloudEvents in my application using the Symfony Messenger component. I have two queues, both of which should handle CloudEvents. Here is my current configuration: routing: '...
nnikolay's user avatar
  • 1,731
0 votes
0 answers
19 views

Is it possible to listen to an Event dispatched from a MessageHandler (Symfony)

I have an application that executes docker containers in async mode using a messenger (DemoExecution). Hence, the user can launch an execution of the container without waiting its end. We need to know ...
daquarius's user avatar
1 vote
0 answers
117 views

Sentry Queue integration with Symfony messenger

I've been trying to set up Symfony Messenger with Sentry Queues for a while but without any luck. I cannot find any resources online related to this specific topic. I'm trying to use the example ...
krystof18's user avatar
  • 247
0 votes
0 answers
62 views

symfony messenger process stucked

I am using symfony messenger with supervisor to generate a lot of PDFs or doing a lot of tasks. Regularly, my consumer process gets stuck, and I have to restart it manually This morning, when i came ...
pop_up's user avatar
  • 1,539
0 votes
0 answers
60 views

Systemctl not restarting symfony messenger consumer

I have a Symfony (6.4) messenger consumer that processes some background queues. As mentioned in the documentation is a good practice to restart it every hour. So I am using systemctl to handle it. ...
Kaharon's user avatar
  • 395
0 votes
1 answer
360 views

Symfony 6.4 Messenger problem with #[AsMessageHandler(fromTransport: 'sync')]

I have configured my project with Symfony 6.4 and Messenger. I have create 2 transports (sync and async) on an event bus. When I dispatch a message, this message goes on the 2 transports that's what I ...
eldiablo62's user avatar
0 votes
0 answers
77 views

Messenger worker going to "idle" state without exit code #54698

Symfony version(s) affected 7.0 We are using symfony messenger directly through kubernetes command, without supervisor, example of configuration: command: enabled: true cli: '["/bin/sh"] ...
Victor Sorokin's user avatar
0 votes
0 answers
115 views

symfony messenger how to dispatch message to a specific queue from PHP?

How to dispatch from PHP (without going through MESSENGER_TRANSPORT_DSN=amqp://xxx) ? default is "message" but if I want queue_nameX ? $bus->dispatch($message, [ //new ...
stloc's user avatar
  • 1,528
0 votes
1 answer
200 views

Symfony, Messenger, Kubernetes and messenger:stop-workers

My problem is as follows, I have a symfony application. It is dockerized in Kubernetes. One container is a web server, the second is consumer for symfony messenger and the third is symfony messenger ...
Tomek Kobyliński's user avatar
1 vote
0 answers
154 views

Symfony/Messenger no retry when critical exception from a web service

I try to use Symfony/Messenger with a web service. I don't understand why the queue don't retry 3 times when I have a critical error. This is my messenger configuration: framework: messenger: ...
nboulfroy's user avatar
  • 221
2 votes
0 answers
232 views

Symfony messenger with doctrine return "7 no connection to the server"

I have trouble with all my tests Symfony (7.0.4) messenger and handling messages. I have entity ID in message (in aws sqs) and handler loading entity from DB (postgres on diferent server). After ...
KdoSiOdJinud's user avatar
1 vote
0 answers
413 views

Symfony / Messenger consume specific queue

I'm trying to send messages from a specific queue from messenger with Symfony, but I get the error that says that I have not implemented "QueueReceiverInterface", except that on the Symfony ...
Gazouweb's user avatar
0 votes
1 answer
60 views

Get data from async operations

In Symfony 6 I need to call a first object (named Script), then this one is going to call a second object (Rule), and this Rule is going to call a last object (Condition) that performs various ...
arsrobota's user avatar
0 votes
0 answers
107 views

Create a Messenger for multiple image upload traitment

I have a project under Symfony 7. My form has a FileType field in order to upload several images. It works very well but depending on the number of images, it can be very long, I would like to queue ...
SelMaK's user avatar
  • 11
-1 votes
1 answer
2k views

Symfony\\Component\\Messenger\\Bridge\\Amqp\\Transport\\Connection::ack(): Return value must be of type bool, null returned

I get this error when handling message, where is the problem? It works before restart. I can connect to rabbit. I didn't change anything, composer update with that composer config. queue stop working. ...
Developer's user avatar
  • 2,873
0 votes
0 answers
433 views

Why is Symfony messenger sending a message twice before rejecting?

I have implemented a Message Transport protocol in a Symfony-Project, that implements the TransportInterface. While playing around with it and learning how it works, I came across a weird issue that I ...
itinance's user avatar
  • 12.3k
0 votes
0 answers
107 views

How to avoid Symfony Messenger wrapping the message into an object with a message key?

I am using Symfony Messenger 6.3 (with Symfony 6.3) to publish a message on a RabbitMQ exchange. The problem is that Symfony Messenger automatically wraps my message into a message object which has a ...
lil's user avatar
  • 5
0 votes
0 answers
183 views

Deleting redis messages from sumfony queue only on success

I have a Redis queue, constantly filling up from a "Manager" and then multiple workers handling the messages. Each worker is in a separate pod (k8s). Currently, I have delete_after_ack set ...
DreamWave's user avatar
  • 1,940
-1 votes
1 answer
281 views

symfony/docker | save in db email sent with messenger

in a symfony project with docker environment, I use the Messenger component, I configured it, the emails are sent via messenger, nice. When emails are sent they disappear from the "...
Eclip tique's user avatar
2 votes
2 answers
567 views

Symfony Messenger Undefined constant SIGTERM

I have a problem with Symfony messenger, I have installed the redis extension, Symfony Messenger Redis package and the problem occurs when the command "php bin/console messenger:consume async&...
Neural Framework's user avatar
0 votes
0 answers
31 views

Symfony Messanger getPathInfo() on null error

some one help me for that when I save a new que data then I runned command but I get this error failed: Call to a member function getPathInfo() on null what is the problem ? What I doing wrong or ...
Durmuş Akman's user avatar
1 vote
1 answer
791 views

Symfony - Sending Failed Messages on purpose

I'm currently using Messenger to send mails with Mailer through my MessageHandler. Here's my messenger.yaml config file. # config/packages/messenger.yaml framework: messenger: transports: ...
Venerivagus's user avatar
0 votes
1 answer
669 views

How to check if I'm already in a message handler when dispatching a new message in Symfony Messenger?

I'm trying to log every message that goes through Symfony Messenger, along with every information I can gather: message dispatched at <timestamp> message handled / failed / retried at <...
BenMorel's user avatar
  • 36.1k
-2 votes
1 answer
375 views

Symfony - Get the state of the mail sended with Messenger

I'm currently using Symfony Messenger on my project. I'm using it to send mails through the MessageHandler Heres the file : <?php namespace App\MessageHandler; use App\Entity\Dossier; use App\...
Venerivagus's user avatar
0 votes
1 answer
490 views

retrying messenger message from a Symfony controller

I need to retry a specific failed messenger message from a Symfony controller. When I try to retrieve failed messages by $this->failedTransport->get(); all messages are cleared which is not what ...
brnina's user avatar
  • 27
-3 votes
1 answer
452 views

Symfony 5.4 with Kafka [closed]

I have a symfony 5.4 project and I want to implement kafka with the symfony messenger component. I've seen several ways to do this, including this post: Symfony Messenger with Apache Kafka as queue ...
user13410345's user avatar
0 votes
0 answers
84 views

Unable to send dkim signed templated email via messenger async in Symfony 6.2

I'm going to run production project but still cannot resolve a problem with sending signed templated email. I've googled and there are a few people with the same problem without clear answer. I ...
Pavel's user avatar
  • 1
1 vote
1 answer
1k views

Symfony Messenger component and redis transport: messages are processed on all queues

I have 4 message queues that use Redis as transport and are each fired in their respective worker (via Supervisor), but every time a message lands in one of the queues, it gets processed in all of ...
Francisco's user avatar
  • 265
3 votes
0 answers
572 views

Symfony Messages are not sent to failure transport

I'm working with Symfony Messenger (Symfony 5.4), trying to use an async transport with multiple retries. As a fallback I would like to use a failure transport. My Messenger configuration is: ...
arsrobota's user avatar
0 votes
1 answer
385 views

What Symfony ValidationMiddleware really do?

I'm trying to understand what Symfony ValidationMiddleware do when it is enabled. Validate what and how and when? I didn't see any difference in my app when it's enabled or disabled. Except ...
deoomen's user avatar
  • 200
0 votes
1 answer
510 views

Api-platform - docker. What is the best way to consume messenger buses from then a containerized service?

I'm interested to know your opinions. By working from the api platform stack (https://github.com/api-platform/api-platform), I want to minimize manual intervention on the deployment of my project I ...
Jonathan Morel's user avatar
1 vote
1 answer
964 views

Why does Symfony debug:messenger command show my messenger handler twice when I use AsMessageHandler attribute?

My Symfony 6.2 bundle has an handler like the following use Symfony\Component\Messenger\Attribute\AsMessageHandler; #[AsMessageHandler] class MyHandler { public function __invoke(MyMessage $...
FabioFLX's user avatar
0 votes
0 answers
293 views

Symfony messenger + RabbitMQ on a Kubernetes cluster : performance issue

Let me first introduce the cluster : 3 nodes ( 8 core + 30Gi each) Volume working as ReadWriteMany with a nfs controler Deployment kube PHPFPM : dispatch symfony messages CRD Rabbitmq for handling ...
Julien Delko's user avatar
8 votes
1 answer
2k views

Library error: a socket error occurred in Symfony Messenger

In my Symfony project, there is a queue message handler, and I have an error that randomly appears during the execution: [2022-10-12T07:31:40.060119+00:00] console.CRITICAL: Error thrown while running ...
Davide Pastore's user avatar
0 votes
0 answers
1k views

How to get symfony messenger Messages before handler consumes them?

I wonder how to get messages which are waiting in my Failed queue from a controller, before the handler consume them. I don't persist them with doctrine, I put them in a rabbitmq that I can see them ...
L01C's user avatar
  • 693
1 vote
1 answer
3k views

Symfony 6 mailer DSN with SMTP doesn't send mails

I'm trying Symfony 6 Mailer with different SMTP servers and none of them is working. The messages are queued but not sent. I tried from different servers to discard a firewall or port issue. There are ...
K. Weber's user avatar
  • 2,743
0 votes
3 answers
903 views

Symfony Messenger Injection Doctrine

I need help for my project. I try to inject Entity Manager inside my service (SendInBlueService) call with messenger, but DependencyInjection can't find doctrine.orm.entity_manager. My test route #[...
JeremK's user avatar
  • 11
3 votes
1 answer
913 views

When I try to send an email, it is not sent, but stored in the messenger_messages table

create a new project Symfony preparing users for enrollment setup symfony console make:user create a registration form symfony console make:registration-form do symfony composer require symfonycasts/...
boss.rus's user avatar
0 votes
1 answer
987 views

Symfony 6 - stop and start Message Messenger systemd worker as www-data user via PHP

I am currently working on a Symfony 6 project. Now I have the situation that I want to stop and start a systemd service which is used to consume the messages from the Symfony Messenger message queue. ...
schwaluck's user avatar
  • 145
3 votes
1 answer
540 views

Symfony SyncTransport dispatches twice

I don't know if it's a bug or feature or concept that I don't get at the moment, so please enlighten me. public function send(Envelope $envelope): Envelope { /** @var SentStamp|null $sentStamp */ ...
dark_982's user avatar
  • 192
3 votes
0 answers
2k views

How to check if symfony messenger is working

I have a pod running in kubernetes / aws cloud. Due to limited configuration options in a custom deployment process (not my fault!!) I cannot start the symfony messenger as you usually would start it. ...
Calamity Jane's user avatar
1 vote
0 answers
866 views

Manually config message dispatcher

For reasons I want to dispatch a message to an AMQP queue, but I can't use the messenger config. My service needs to dispatch to various queues, setting the config for each one is not a viable uption ...
Martijn's user avatar
  • 16k
1 vote
0 answers
511 views

composer install messenger generating erros on clearing the cache

trying to install symfony/messenger. The script seems to be generating an error message when trying to install it, it goes thru the components is installed, issues start once the composer is launching ...
Dezz H's user avatar
  • 400
0 votes
0 answers
1k views

Symfony messenger message lost after running out of memory

I'm creating an application in Symfony, and I need to retrieve a large number of customer records (tens of thousands) from an external API endpoint, then store it in a Doctrine database. The API will ...
ReeceNG's user avatar
0 votes
0 answers
228 views

Undefined class 'MessageHandlerInterface'

I am trying to implement symfony/messenger to my current Symfony 5.4 project. I have installed composer require messenger Next, I try to create a handler class SmsNotificationHandler implements ...
user1687891's user avatar
1 vote
0 answers
1k views

Symfony Messenger Performance

I have a performance problem running some RabbitMQ queues on both my local machine and on the production server. At first I thought that it was the consumer which connects to DB and runs some queries, ...
The50's user avatar
  • 1,138
0 votes
1 answer
986 views

Symfony Messenger sequential message processing and the x-single-active-consumer argument on RabbitMQ

I use Symfony Messenger with the RabbitMQ adapter in my application. The logic of the application is that messages from the same queue must be executed sequentially, one after the other (the order is ...
WindBridges's user avatar
0 votes
0 answers
934 views

Symfony Messenger - working with multiple schemas

Background I am working with multiple postgres schemas that basically identify as individual tenants sharing the app. Every request that the backend receives contains an instance identifying header ...
Luke's user avatar
  • 565
3 votes
0 answers
9k views

Symfony 6 - Creating excel with PHPSpreadsheet and downloading it asynchronously

I'm stuck on something, and it seems internet haven't had this problem (or i haven't got the right keyword to find the answer) Keep in mind that I'm still learning Symfony 6 and I'm a bit by myself ...
Corentin Durey's user avatar