Skip to content

Exceptions with requests #24

Open
Open
@PNixx

Description

@PNixx

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

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions