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