code: public function create($connectionName, $exchangeName, Channel $channel = null, array $options = [])
      {
          $connection = $this->connectionRegistry->getConnection($connectionName);
  
          return $this->createFromConnection($connection, $exchangeName, $channel, $options);
      }
docs: @param string $connectionName
  @param string $exchangeName
  @param array  $options
  
  @return Publisher