137
questions
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 ...
-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:
'...
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 ...
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 ...
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 ...
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.
...
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 ...
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"]
...
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 ...
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 ...
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:
...
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 ...
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 ...
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 ...
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 ...
-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.
...
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 ...
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 ...
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 ...
-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 "...
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&...
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 ...
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:
...
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 <...
-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\...
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 ...
-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 ...
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 ...
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 ...
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:
...
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 ...
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 ...
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 $...
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 ...
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 ...
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 ...
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 ...
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
#[...
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/...
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.
...
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 */
...
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. ...
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 ...
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 ...
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 ...
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 ...
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, ...
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 ...
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 ...
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 ...