Skip to content

[Bug] AsyncListener recieve wrong eventQueue #690

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
grachevko opened this issue Dec 14, 2018 · 7 comments · Fixed by #694
Closed

[Bug] AsyncListener recieve wrong eventQueue #690

grachevko opened this issue Dec 14, 2018 · 7 comments · Fixed by #694

Comments

@grachevko
Copy link

AsyncListener recieve only symfony_events in $eventQueue, without prefix and app_name

@makasim
Copy link
Member

makasim commented Dec 14, 2018

AsyncListneer works on transport level, Client is a higher abstraction.

@grachevko
Copy link
Author

@makasim okey, but documentation has no information about this behaviour. Moreover async-event-dispatcher not working out of the box with default parameters from docs.

After hours of debugging, to start it working i had to write this

$container->getDefinition('enqueue.events.async_listener')
    ->replaceArgument(2, 'enqueue.app.symfony_events');

Because consumer listening enqueue.app.symfony_events, while AsyncListener push events to symfony_events queue.

@makasim
Copy link
Member

makasim commented Dec 14, 2018

@makasim
Copy link
Member

makasim commented Dec 14, 2018

There is a bug, this command subscriber options should be adjusted here

https://github.com/php-enqueue/enqueue-dev/blob/master/pkg/async-event-dispatcher/AsyncProcessor.php#L57

@makasim
Copy link
Member

makasim commented Dec 14, 2018

@grachevko
Copy link
Author

@makasim yes tried, it crash client, because it publish to enqueue.app.enqueue.app.symfony_events

@GCalmels
Copy link
Contributor

GCalmels commented Jan 7, 2019

Hello, I have the same issue but I have the last changed files... If I change enqueue_events_queue to enqueue.app.symfony_events, I have : enqueue.app.enqueue.app.symfony_events...
I don't know how to set the right queue name.

The option for a route is prefix_queue and for the processor, the option is queue_prefixed, is it an error ?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging a pull request may close this issue.

3 participants