src/Transport/RabbitMq/RabbitMqQueueCreator.php
public function createIfNecessary(QueueBindings $queueBindings)
    {
        $addresses = array_merge($queueBindings->getReceivingAddresses(), $queueBindings->getSendingAddresses());
        foreach ($addresses as $address) {
            $this->routingTopology->setupForEndpointUse($this->brokerModel, $address);
        }
    }
public function createIfNecessary(QueueBindings $queueBindings)
    {
        $addresses = array_merge($queueBindings->getReceivingAddresses(), $queueBindings->getSendingAddresses());
        foreach ($addresses as $address) {
            $this->routingTopology->setupForEndpointUse($this->brokerModel, $address);
        }
    }
public function createIfNecessary ( QueueBindings $ queueBindings ) { $ addresses = array_merge ( $ queueBindings -> getReceivingAddresses ( ) , $ queueBindings -> getSendingAddresses ( ) ) ; foreach ( $ addresses as $ address ) { $ this -> routingTopology -> setupForEndpointUse ( $ this -> brokerModel , $ address ) ; } }
Creates message queues for the defined queue bindings.

@param QueueBindings $queueBindings
Creates message queues for the defined queue bindings .