EventDispatcher is by design synchronous, i.e. the same process works on whatever you want it to do
Symfony Messenger is similar in that it has a routing mechanism and can work both synchronously and asynchronously - putting workload to other processes to do later (in async there is no feedback - original process "dispatches" a message to transport and consuming process pick it up when it's not doing anything)
UniqueJobs or returned values (at least not yet)
./composer.json has been updated
Loading composer repositories with package information
Updating dependencies (including require-dev)
Your requirements could not be resolved to an installable set of packages.
Problem 1
- Can only install one of: queue-interop/queue-interop[0.8.0, 0.6.2].
- Can only install one of: queue-interop/queue-interop[0.8.0, 0.6.2].
- Can only install one of: queue-interop/queue-interop[0.8.0, 0.6.2].
- enqueue/fs 0.10.1 requires queue-interop/queue-interop ^0.8 -> satisfiable by queue-interop/queue-interop[0.8.0].
- Installation request for enqueue/fs ^0.10.1 -> satisfiable by enqueue/fs[0.10.1].
- Installation request for queue-interop/queue-interop (locked at 0.6.2) -> satisfiable by queue-interop/queue-interop[0.6.2].queue-interop/queue-interop is locked on lower version
Hello,
I am working on a Symfony application and wanted to use the async dispatcher. I have a symfony command that should dispatch multiple events. Then wait till they finish. However what happens now, is that the command dispatches the event but doesn’t wait till it is finished. Which has the effect that the eventListener doesn’t execute.
How do I wait until all async events are finished? Thanks in advance for helping.
class TestWebpageCommand extends Command
{
protected static $defaultName = 'test-webpage';
private $em;
/* @var OutputInterface /
private $output;
private $dispatcher;
public function construct(EventDispatcherInterface $dispatcher, EntityManagerInterface $em)
{
$this->em = $em;
$this->dispatcher = $dispatcher;
parent::construct();
}
protected function initialize(InputInterface $input, OutputInterface $output)
{
$this->output = $output;
}
protected function execute(InputInterface $input, OutputInterface $output)
{
$output->writeln("start");
$event = new onStartSpeedTest();
$this->dispatcher->dispatch($event);
$event = new onStartSpeedTest();
$this->dispatcher->dispatch($event);
$output->writeln("end");
}
}
@Vescatur
How do I wait until all async events are finished?
you don't. that's quite the point of async events - you don't wait for them to get finished. if you need the result of some async procedure, then you need to either use RPC as @makasim suggests, or if you need to stick with events, return the result via another queue/event.
The problem that I am having is that the events have been dispatch but the eventListeners never execute anything. I never see a result in the database. How can I ensure that the eventListeners can react to the event when using a async dispatcher?
To ensure I didn't have a bug I tested my code with a synchronous dispatcher. Then I get the results in the database.
Hi there, I am using Symfony 3.4 and Enqueue (0.9.15) over Dbal, I can produce a message, I have see them in DB but I am cannot process it,
All that I have to see in console is
./c enqueue:consume --setup-broker -vvv
18:58:55 DEBUG [app] [DbalDriver] Creating database table: "enqueue"
and it all, no any other output.
$messageTopic = $this->context->createTopic('notification_processor');
$message = new DbalMessage(
$body,
$properties,
$headers
);
$this->context->createProducer()->send($messageTopic, $message);and processor
class NotificationProcessor implements Processor, TopicSubscriberInterface
{
...
public static function getSubscribedTopics()
{
return ['notification_processor'];
}
}I have see this processor in enqueue:routes result
What I am doing wrong?
Hello guys, i am looking for possibility to do this: i have 2 apps, both just plane symfony4 + enqueue-bundle + enqueue/amqp-ext, first is used to consume messages, second will send commands to first app, like microservices, so i need reply in second app from first one, but enqueue-bundle in second app doesnt know about routes for processors registered in first app, how i can deal with it in context of enqueue-bundle? i always get There is no route for command on second app. And its true because its registered in first app. How i can deal with it? )
I had similar issue, I ended up setting up dummy routes for the second app, kind of like interfaces with no actual code, so that it just knows that they exist. Kind of dirty, but it worked fine. Not sure if there's any better way of doing this.
