Skip to content

added support of multiple consumer for single transport#104

Open
oleg-andreyev wants to merge 2 commits into
jwage:mainfrom
oleg-andreyev:multiple-queue-single-transport
Open

added support of multiple consumer for single transport#104
oleg-andreyev wants to merge 2 commits into
jwage:mainfrom
oleg-andreyev:multiple-queue-single-transport

Conversation

@oleg-andreyev

Copy link
Copy Markdown

fixes #103


use function iterator_to_array;

class ConnectionMultipleQueueTest extends TestCase

Copy link
Copy Markdown
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

essentially copy/paste

self::assertCount(0, iterator_to_array($amqpEnvelopes2));
}

public function testPublish(): void

Copy link
Copy Markdown
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

haven't yet figured out how to do real publish

@jwage

jwage commented Nov 5, 2025

Copy link
Copy Markdown
Owner

This seems fine to me, but I don't have this use case in my app so it is hard for me to test it robustly. Since consume() is blocking and streams the messages, how does this behave? Does one queue consume block the others?

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 this pull request may close these issues.

Multiple queues on single transport

2 participants