public function create($connectionName, $exchangeName, Channel $channel = null, array $options = [])
    {
        $connection = $this->connectionRegistry->getConnection($connectionName);

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

        return $this->createFromConnection($connection, $exchangeName, $channel, $options);
    }
@param string $connectionName
@param string $exchangeName
@param array  $options

@return Publisher