Dynamic transport creation

[DruGity]

What i need is to create several queues right in code with different names, not in messenger.yaml. I have tried to do it with TransportFactory, but it is not what i need.
So the question is - Can i create queues dynamically? Does such opportunity exists in Messenger component?

[chalasr]

I have tried to do it with TransportFactory, but it is not what i need.

Then can you explain what you mean by "creating queues dynamically"?
If what you want is to create the queue on the transport (doctrine:database:create like) then the SetupableTransportInterface coming in Symfony 4.3 might be the solution.

$transport = $transportFactory->createTransport('dsn');
$transport->setup();

It is implemented by all built-in transports.

[DruGity]

What i need is to create several queues with different names, something like this:

foreach($array as $item) {
    $channel = $bunny->channel();
    $channel->queueDeclare($item['name']); 
}

Like in https://packagist.org/packages/bunny/bunny library
Can i do so in The Messenger Component? Because what i see now - that i can only create one transport with one queue.

[chalasr]

The low-level AmqpFactory seems to be what you are looking for.
Please check the class and its usages to see what you can do with it and tell us if you think there is something more to do in Symfony.
If you need help for experimenting, please try our support platforms and close this issue.
Thank you

[DruGity]

Thanks, you are absolutely right about low-level AmqpFactory. I used another library for my needs. I wish The Messenger had such opportunity, but its great even without it)

[oleg-andreyev]

@DruGity Ideally queues are created by consumers, so for each "dynamic" queue you need to create a consumer with correct bindings and publisher just uses AmqpStamp with binding and publish should declare only exchange.