"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "src/Symfony/Component/Messenger/Transport/RedisExt/Connection.php" between
symfony-4.4.14.tar.gz and symfony-4.4.15.tar.gz

About: Symfony is a web application framework for PHP projects. Source code (4.4 series).

Connection.php  (symfony-4.4.14):Connection.php  (symfony-4.4.15)
skipping to change at line 64 skipping to change at line 64
$this->connection = $redis ?: new \Redis(); $this->connection = $redis ?: new \Redis();
$this->connection->connect($connectionCredentials['host'] ?? '127.0.0.1' , $connectionCredentials['port'] ?? 6379); $this->connection->connect($connectionCredentials['host'] ?? '127.0.0.1' , $connectionCredentials['port'] ?? 6379);
$this->connection->setOption(\Redis::OPT_SERIALIZER, $redisOptions['seri alizer'] ?? \Redis::SERIALIZER_PHP); $this->connection->setOption(\Redis::OPT_SERIALIZER, $redisOptions['seri alizer'] ?? \Redis::SERIALIZER_PHP);
$auth = $connectionCredentials['auth'] ?? null; $auth = $connectionCredentials['auth'] ?? null;
if ('' === $auth) { if ('' === $auth) {
$auth = null; $auth = null;
} }
if (null !== $auth && !$this->connection->auth($auth)) { if (null !== $auth && !$this->connection->auth($auth)) {
throw new InvalidArgumentException('Redis connection failed: '.$redi s->getLastError()); throw new InvalidArgumentException('Redis connection failed: '.$this ->connection->getLastError());
} }
if (($dbIndex = $configuration['dbindex'] ?? self::DEFAULT_OPTIONS['dbin dex']) && !$this->connection->select($dbIndex)) { if (($dbIndex = $configuration['dbindex'] ?? self::DEFAULT_OPTIONS['dbin dex']) && !$this->connection->select($dbIndex)) {
throw new InvalidArgumentException('Redis connection failed: '.$redi s->getLastError()); throw new InvalidArgumentException('Redis connection failed: '.$this ->connection->getLastError());
} }
foreach (['stream', 'group', 'consumer'] as $key) { foreach (['stream', 'group', 'consumer'] as $key) {
if (isset($configuration[$key]) && '' === $configuration[$key]) { if (isset($configuration[$key]) && '' === $configuration[$key]) {
throw new InvalidArgumentException(sprintf('"%s" should be confi gured, got an empty string.', $key)); throw new InvalidArgumentException(sprintf('"%s" should be confi gured, got an empty string.', $key));
} }
} }
$this->stream = $configuration['stream'] ?? self::DEFAULT_OPTIONS['strea m']; $this->stream = $configuration['stream'] ?? self::DEFAULT_OPTIONS['strea m'];
$this->group = $configuration['group'] ?? self::DEFAULT_OPTIONS['group'] ; $this->group = $configuration['group'] ?? self::DEFAULT_OPTIONS['group'] ;
 End of changes. 2 change blocks. 
2 lines changed or deleted 2 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)