Open
Description
I try subscribe to channel with:
yield $channel->consume('onMessage', 'queue', 'tag');
yield $channel->consume('onMessage', 'queue', 'tag');
For first request it working, but for the second it remains pending for a long time.
In rabbitmq I see:
operation basic.consume caused a connection exception not_allowed: "attempt to reuse consumer tag 'tag'"
This also applies to the queueDeclare method with different parameters.
I think need to throw an exception when the server raises an error.
Metadata
Metadata
Assignees
Labels
No labels