src/PubSubConnectionFactory.php
public function make($driver, array $config = [])
    {
        switch ($driver) {
            case '/dev/null':
                return new DevNullPubSubAdapter();
            case 'local':
                return new LocalPubSubAdapter();
            case 'redis':
                return $this->makeRedisAdapter($config);
            case 'kafka':
                return $this->makeKafkaAdapter($config);
            case 'gcloud':
                return $this->makeGoogleCloudAdapter($config);
            case 'http':
                return $this->makeHTTPAdapter($config);
        }

        throw new InvalidArgumentException(sprintf('The driver [%s] is not supported.', $driver));
    }
public function make($driver, array $config = [])
    {
        switch ($driver) {
            case '/dev/null':
                return new DevNullPubSubAdapter();
            case 'local':
                return new LocalPubSubAdapter();
            case 'redis':
                return $this->makeRedisAdapter($config);
            case 'kafka':
                return $this->makeKafkaAdapter($config);
            case 'gcloud':
                return $this->makeGoogleCloudAdapter($config);
            case 'http':
                return $this->makeHTTPAdapter($config);
        }

        throw new InvalidArgumentException(sprintf('The driver [%s] is not supported.', $driver));
    }
public function make ( $ driver , array $ config = [ ] ) { switch ( $ driver ) { case '/dev/null' : return new DevNullPubSubAdapter ( ) ; case 'local' : return new LocalPubSubAdapter ( ) ; case 'redis' : return $ this -> makeRedisAdapter ( $ config ) ; case 'kafka' : return $ this -> makeKafkaAdapter ( $ config ) ; case 'gcloud' : return $ this -> makeGoogleCloudAdapter ( $ config ) ; case 'http' : return $ this -> makeHTTPAdapter ( $ config ) ; } throw new InvalidArgumentException ( sprintf ( 'The driver [%s] is not supported.' , $ driver ) ) ; }
Factory a PubSubAdapterInterface.

@param string $driver
@param array $config

@return PubSubAdapterInterface
Factory a PubSubAdapterInterface .