src/Consumer/ConsumerFactory.php
public function create($connectionName, $exchangeName, $queueName)
    {
        $connection = $this->connectionRegistry->getConnection($connectionName);

        return $this->createFromConnection($connection, $exchangeName, $queueName);
    }
public function create($connectionName, $exchangeName, $queueName)
    {
        $connection = $this->connectionRegistry->getConnection($connectionName);

        return $this->createFromConnection($connection, $exchangeName, $queueName);
    }
public function create ( $ connectionName , $ exchangeName , $ queueName ) { $ connection = $ this -> connectionRegistry -> getConnection ( $ connectionName ) ; return $ this -> createFromConnection ( $ connection , $ exchangeName , $ queueName ) ; }
@param string $connectionName
@param string $exchangeName
@param string $queueName

@return Consumer
@param string $connectionName @param string $exchangeName @param string $queueName