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